flink 检查点卡在收到 0 个字节的子任务上
flink checkpoint stuck on subtask with 0 bytes received
其中一个子任务没有任何输入（即接收到的字节为0），并且该子任务的检查点卡住了。
是正常现象，还是bug？
flink版本为1.6.2
添加更多信息。
下面是拓扑。
而第三个任务（即'Window(TumblingProcessingTimeWindows(30000), ProcessingTimeTrigger, ScalaReduceFunction, PassThroughWindowFunction) -> Map -> Sink: Unnamed'）有五个子任务，其'Bytes received'为0。检查点卡在这五个子任务上。其中一个子任务如下所示。
而且每次我重新启动应用程序时，'Bytes received 0' 都会发生在不同数量的子任务上。
为什么？
Flink 1.6.2 有一些与检查点相关的错误。也许您可以升级到 1.6.4，看看是否可以解决问题？
其中一个子任务没有任何输入（即接收到的字节为0），并且该子任务的检查点卡住了。
是正常现象，还是bug？
flink版本为1.6.2
添加更多信息。
下面是拓扑。
而第三个任务（即'Window(TumblingProcessingTimeWindows(30000), ProcessingTimeTrigger, ScalaReduceFunction, PassThroughWindowFunction) -> Map -> Sink: Unnamed'）有五个子任务，其'Bytes received'为0。检查点卡在这五个子任务上。其中一个子任务如下所示。
而且每次我重新启动应用程序时，'Bytes received 0' 都会发生在不同数量的子任务上。
为什么？
Flink 1.6.2 有一些与检查点相关的错误。也许您可以升级到 1.6.4，看看是否可以解决问题？