But it's failing though, and I am getting this message as well, Checkpoint Timer] INFO org.apache.flink.runtime.checkpoint.CheckpointFailureManager - Failed to trigger checkpoint for job 688f9f7c6d0fdc8457474fd7f6911049 since Checkpoint triggering task Source: SG-SGT-TransformerJob -> Map -> Sink: Writer -> Sink: Committer (1/10) of job 688f9f7c6d0fdc8457474fd7f6911049 is not being executed at the moment. Aborting checkpoint. Failure reason: Not all required tasks are currently running..