Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
对于intervaljoin类型的任务,配置jobmanag
er.execution.failover-strategy为
region时,会触发频繁的task cancel
Classic
List
Threaded
♦
♦
Locked
1 message
jiafu
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
对于intervaljoin类型的任务,配置jobmanag
er.execution.failover-strategy为
region时,会触发频繁的task cancel
使用的flink版本是1.8.1,配置了局部重启策略。jobmanager.execution.failover-strategy:region。
任务拓扑如下:
测试时,kill掉其中一个taskmanager,因为该任务存在shuffle会被当成一个region来重启,出现了source不断的收到cancel消息,状态从DEPLOY不断的转换成cancel。
这样的消息数量竟然多大1300多条
Free forum by Nabble
Edit this page