Flink 作业因“检查点协调器正在暂停”而失败。答案

【问题标题】：Flink job failed with "Checkpoint Coordinator is suspending."Flink 作业因“检查点协调器正在暂停”而失败。
【发布时间】：2020-10-10 09:47:11
【问题描述】：

我运行了一个 flink 作业，但在 18 小时后它失败了。失败消息：检查点协调器正在暂停。

检查点截图：

工作概览截图：

这是作业管理器日志：

2020-10-10 13:53:10,636 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: kafkaSource -> Timestamps/Watermarks -> Process (1/1) (c38419ece8208c1ef2948087f2b84dd0) switched from RUNNING to FAILED.
java.lang.Exception: Could not perform checkpoint 3265 for operator Source: kafkaSource -> Timestamps/Watermarks -> Process (1/1).
    at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:785)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$triggerCheckpointAsync$3(StreamTask.java:760)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.run(StreamTaskActionExecutor.java:87)
    at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
    at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:261)
    at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:186)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:485)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:469)
    at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:708)
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:533)
    at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NullPointerException
    at org.apache.flink.streaming.runtime.tasks.StreamTask$CheckpointingOperation.executeCheckpointing(StreamTask.java:1394)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.checkpointState(StreamTask.java:974)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$5(StreamTask.java:870)
    at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:843)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:776)
    ... 11 more

我不知道是什么导致了这个问题。

【问题讨论】：

您在日志中看到了什么？ Job Manager 和 Task Manager 日志都可能有有价值的线索。
投票关闭，因为如果没有去年要求的进一步信息，它不太可能被复制或解决。

标签： apache-flink flink-streaming

【解决方案1】：

当您的应用程序尝试检查点时，可能会发生这种情况，此时检查点协调器（作业管理器）由于某种原因关闭，并且检查点无法完成。关闭的原因可能有多种原因，例如，您开始了新的部署、取消了作业、作业由于某些运行时异常而不得不退出等等。

【讨论】：