flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [flink] fapaul commented on pull request #16472: [FLINK-23183][connectors/rabbitmq] Fix ACKs for redelivered messages in RMQSource
Date Wed, 21 Jul 2021 07:08:41 GMT

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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



Mime
View raw message