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

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