请教关于Flink算子FINISHED状态时无法保存Checkpoint的问题

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

请教关于Flink算子FINISHED状态时无法保存Checkpoint的问题

yj5182
请教大家一个我最近在配置Flink流的过程中遇到问题,
flink作业中关联使用了物理表(字典表),在flinkjob启动后,会对字典表进行一次读取,然后该算子会变成FINISHED状态,导致该flinkjob无法保存checkpoint和savepoint。一般大家遇到这种问题都是怎么处理的,我这个作业在数据加工过程中必须用到字典表赋值。




Reply | Threaded
Open this post in threaded view
|

Re: 请教关于Flink算子FINISHED状态时无法保存Checkpoint的问题

yulu yang
对了,我这个flink作业和和分组都是新创建,不存在抽取历史。

杨豫鲁 <[hidden email]> 于2020年8月13日周四 下午3:33写道:

> 请教大家一个我最近在配置Flink流的过程中遇到问题,
>
> flink作业中关联使用了物理表(字典表),在flinkjob启动后,会对字典表进行一次读取,然后该算子会变成FINISHED状态,导致该flinkjob无法保存checkpoint和savepoint。一般大家遇到这种问题都是怎么处理的,我这个作业在数据加工过程中必须用到字典表赋值。
>
>
>
>
>
Reply | Threaded
Open this post in threaded view
|

Re: 请教关于Flink算子FINISHED状态时无法保存Checkpoint的问题

Congxian Qiu
这个问题和下面这个问题[1] 重复了,在另外的邮件列表中已经有相关讨论

[1]
http://apache-flink.147419.n8.nabble.com/Flink-FINISHED-Checkpoint-td6008.html
Best,
Congxian


yulu yang <[hidden email]> 于2020年8月14日周五 下午1:05写道:

> 对了,我这个flink作业和和分组都是新创建,不存在抽取历史。
>
> 杨豫鲁 <[hidden email]> 于2020年8月13日周四 下午3:33写道:
>
> > 请教大家一个我最近在配置Flink流的过程中遇到问题,
> >
> >
> flink作业中关联使用了物理表(字典表),在flinkjob启动后,会对字典表进行一次读取,然后该算子会变成FINISHED状态,导致该flinkjob无法保存checkpoint和savepoint。一般大家遇到这种问题都是怎么处理的,我这个作业在数据加工过程中必须用到字典表赋值。
> >
> >
> >
> >
> >
>