fapaul commented on pull request #16472: URL: https://github.com/apache/flink/pull/16472#issuecomment-883947518
My idea is to create an example job that fails on `notifyCheckpointCompleted` i.e. a custom Map function before the sink. This should prevent the sink from receiving the `notifyCheckpointCompleted` event and the pipeline is restarted. Overall, I started wondering because the next checkpoint after the job is restarted should acknowledge all the pending records. Can you elaborate a bit more on the prefecht scenario? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
