An example can be found at <https://github.com/imm...
# troubleshootingm
Martijn Visser
10/27/2023, 7:02 AMAn example can be found at https://github.com/immerok/recipes/tree/main/kafka-exactly-once
c
Chennupati Gopal
10/27/2023, 9:51 AMHi Martijn,
Even this example is having the same issue, it just fails to complete the checkpoint
[Checkpoint Timer] INFO org.apache.flink.runtime.checkpoint.CheckpointFailureManager - Failed to trigger checkpoint for job a2a5e1784e5539fce8e097f9d3318756 since Checkpoint triggering task Source: KafkaExactlyOnce -> Sink: Writer -> Sink: Committer (1/10) of job a2a5e1784e5539fce8e097f9d3318756 is not being executed at the moment. Aborting checkpoint. Failure reason: Not all required tasks are currently running..
m
Martijn Visser
10/27/2023, 10:05 AMAgain, this is an INFO statement
Martijn Visser
10/27/2023, 10:05 AMPlease check your log files for the actual ERROR log