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

Sun, 16 Aug 2020 20:28:58 -0700 

Hi  吴磊
    请问你们有比较过使用 Redis 和 broadcast state 在你们场景下的区别吗？是什么原因让你们选择 Redis 而不是
BroadcastState 呢？

Best,
Congxian


吴磊 <[email protected]> 于2020年8月14日周五 下午3:39写道：

> 在我们的生产环境最常用的做法都是通过维表关联的方式进行赋值的；
> 或者可以先将字典数据写进redis，然后再在第一次使用的时候去访问redis，并加载到State中。
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> [email protected]&gt;;
> 发送时间:&nbsp;2020年8月13日(星期四) 中午1:49
> 收件人:&nbsp;"user-zh"<[email protected]&gt;;
>
> 主题:&nbsp;请教关于Flink算子FINISHED状态时无法保存Checkpoint的问题
>
>
>
> 请教大佬一个我最近在配置Flink流的过程中遇到问题，
>
> flink作业中关联使用了物理表（字典表），在flinkjob启动后，会对字典表进行一次读取，然后该算子会变成FINISHED状态，导致该flinkjob无法保存checkpoint和savepoint。一般大家遇到这种问题都是怎么处理的，我这个作业在数据加工过程中必须用到字典表赋值。

回复