我在一台机器上启动flink(bin/start cluster.sh),并通过FlinkWebUI提交作业。如果作业有问题,如sink mysql表不存在或keyby字段错误,不仅此作业失败,我必须取消失败的任务,但取消后,taskmanager就像被“杀死”了一样,消失在flink web ui中。
是否有容错解决方案(taskmanager会被失败的作业杀死)?唯一的办法就是用毛线绕Flink?
我在一台机器上启动flink(bin/start cluster.sh),并通过FlinkWebUI提交作业。如果作业有问题,如sink mysql表不存在或keyby字段错误,不仅此作业失败,我必须取消失败的任务,但取消后,taskmanager就像被“杀死”了一样,消失在flink web ui中。
是否有容错解决方案(taskmanager会被失败的作业杀死)?唯一的办法就是用毛线绕Flink?
1条答案
按热度按时间chhkpiq41#
任务失败不应导致taskmanager被终止。请检查taskmanager日志中是否有任何异常。