Darcy Lin created FLINK-21839: --------------------------------- Summary: SinkFunction snapshotState don't snapshot all data when trigger a stop-with-drain savepoint Key: FLINK-21839 URL: https://issues.apache.org/jira/browse/FLINK-21839 Project: Flink Issue Type: Bug Components: Runtime / Checkpointing Affects Versions: 1.12.2 Reporter: Darcy Lin Attachments: TestSink.java
This problem was discovered when I was developing the flink code. In my flink code, my custom sink don't send all data that be produced by event_time window when trigger stop-with-drain savepoint . TestSink.java is a example that SinkFunction invoke() continues to run after snapshotState() executed when trigger a stop-with-drain savepoint by rest api. {code:java} //TaskSink.java log sink open invoke: 0 invoke: 1 invoke: 2 invoke: 3 invoke: 4 invoke: 5 invoke: 6 invoke: 7 invoke: 8 invoke: 9 ... invoke: 425 invoke: 426 invoke: 427 snapshotState invoke: 428 // It should be executed before snapshotState. sink close{code} -- This message was sent by Atlassian Jira (v8.3.4#803005)