对于intervaljoin类型的任务,配置jobmanager.execution.failover-strategy为region时,会触发频繁的task cancel

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

对于intervaljoin类型的任务,配置jobmanager.execution.failover-strategy为region时,会触发频繁的task cancel

jiafu
使用的flink版本是1.8.1,配置了局部重启策略。jobmanager.execution.failover-strategy:region。
任务拓扑如下:

测试时,kill掉其中一个taskmanager,因为该任务存在shuffle会被当成一个region来重启,出现了source不断的收到cancel消息,状态从DEPLOY不断的转换成cancel。

这样的消息数量竟然多大1300多条