checkpoint问题反馈

[star10k]

大哥们 我不知道是bug还是使用问题 checkpoint无法被执行 state 始终是null ，我看checkpoint只执行了1-2次就终止了。 方式： chunjun json 类型：mysql-mysql同步 描述：比如cp interval = 30秒 , channel = 3 ,运行1-2分钟后 控制台查看到其中1项状态是FINISHED，其他2项是RUNNING。checkpoint一直在运行。然后checkpoint写快照一直无法被调用 . 在org.apache.flink.runtime.checkpoint.CheckpointCoordinator#getTriggerExecutions 这里被终止。

附上日志： 2022-07-04 17:18:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:18:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:19:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:19:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:20:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:20:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:21:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:21:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:22:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:22:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:23:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:23:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:24:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:24:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:25:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:25:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:26:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:26:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:27:04,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2022-07-04 17:27:34,952 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint triggering task Source: mysqlsourcefactory (1/4) of job ba3487aa0c68875240ca5f2b135130a2 is not in state RUNNING but FINISHED instead. Aborting checkpoint.

有大佬 了解此处问题吗 谢谢！！

[Paddy0523]

其中1项状态是FINISHED,可以检查一下是否存在数据倾斜