<
> > hinobl...@gmail.com>;
> > 发送时间: 2022年8月23日(星期二) 晚上11:09
> > 收件人: "user-zh" >
> > 主题: Re: Re: flink1.15.1 stop 任务失败
> >
> >
> >
> > 1 大概率是source部分问题,或者 savepoint 的 trigger 层面。
> > 2 也可以从 cancel 和 stop 的区别上考虑下?
&g
"user-zh"
> <
> hinobl...@gmail.com>;
> 发送时间: 2022年8月23日(星期二) 晚上11:09
> 收件人: "user-zh"
> 主题: Re: Re: flink1.15.1 stop 任务失败
>
>
>
> 1 大概率是source部分问题,或者 sav
Kafka
Connector??Api??IDEAJira
https://issues.apache.org/jira/browse/FLINK-28758
-- --
??:
1 大概率是source部分问题,或者 savepoint 的 trigger 层面。
2 也可以从 cancel 和 stop 的区别上考虑下?
3 补充信息:我的kafka source是用的旧版本(没办法用新版本,原因是由于一些原因我必须用 kafka 低版本 client)。
yidan zhao 于2022年8月23日周二 23:06写道:
>
> 看了下,报错很少。
> 反正 flink cancel -s 是可以的,flink stop 就不行。而且目测是瞬间失败。从web
> ui来看,整个savepoint的完成是0/841,应该是几乎没开始就出错了。
> 目前4台机器
看了下,报错很少。
反正 flink cancel -s 是可以的,flink stop 就不行。而且目测是瞬间失败。从web
ui来看,整个savepoint的完成是0/841,应该是几乎没开始就出错了。
目前4台机器:
机器1
2022-08-23 22:47:37,093 WARN
org.apache.flink.runtime.taskmanager.Task[] -
Source: JobConfig -> Split(JobName_configType)
(1/1)#0 (b5076938b231fb9d33e582104292ebd
补充部分信息:
看日志,如果是 flink savepoint xxx 这样触发检查点,JM的日志很简单:
2022-08-23 20:33:22,307 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] -
Triggering savepoint for job 8d231de75b8227a1b
715b1aa665caa91.
2022-08-23 20:33:22,318 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinato