[FLINK-24128] StreamingFileCommiter receive commit message but checkpoint did't ready

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Component/s: Connectors / FileSystem
• Assignee: Unassigned
• Reporter: zhuzhengjun
• Created: 02/Sep/21 11:41
• Updated: 30/Sep/21 08:09
• Resolved: 30/Sep/21 08:09

Description

Checkpoint(49) has not been snapshot. The watermark information is: {47=1630562415012, 48=-9223372036854775808, 50=1630565549045}.

we find that watermarks did not match checkpoint id.

if EndCompact Message send by notify checkpoint,it will be better?