Flink 检查点被中止

Question

我在 Intellij 中运行 Apache Flink 迷你集群。 尝试设置一个流连接，其中一个流来自 kinesis 源，另一个来自 jdbc。

当我从表源创建数据流时，如下所示：

 // Table with two fields (String name, Integer age)
 Table table = ...

 // convert the Table into an append DataStream of Row by specifying the class
 DataStream<Row> dsRow = tableEnv.toAppendStream(table, Row.class);

我在堆栈跟踪中收到以下信息消息：

INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - Checkpoint triggering task 
 Soource ...  
job bcf73c5d7a0312d57c2ca36d338d4569 is not in state RUNNING but FINISHED instead. Aborting 
checkpoint. 

Answer 1

如果作业的任何任务已运行完成，则不会发生 Flink 检查点。也许您的 jdbc 源已经完成，这阻止了任何进一步的检查点？

Answer 2

您可以检查您的并行设置， 如果您的程序的并行度大于源的并行度，则某些任务将显示完成，因为它没有数据，这将中止检查点。