DTStack / DTStack/chunjun

checkpoint问题反馈

Open
#1,022 1 comment 0 reactions 0 assignees View on GitHub
bug
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

大哥们 我不知道是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.

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

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.