zhuzhengjun created FLINK-24128:
-----------------------------------

             Summary: StreamingFileCommiter receive commit message but 
checkpoint did't ready 
                 Key: FLINK-24128
                 URL: https://issues.apache.org/jira/browse/FLINK-24128
             Project: Flink
          Issue Type: Bug
          Components: Connectors / FileSystem
            Reporter: zhuzhengjun


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,it will be better?



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to