收到,十分感谢,我学习一下! Congxian Qiu <[email protected]> 于2020年8月13日周四 下午2:04写道:
> Hi > 不好意思,上一份邮件没有说完就发送出去了。 > 如果你希望把从其他地方读入 字典表,然后在 flink 中使用,或许可以看看 broadcast state[1] > > [1] > > https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/state/broadcast_state.html > Best, > Congxian > > > Congxian Qiu <[email protected]> 于2020年8月13日周四 下午2:00写道: > > > Hi > > 现在 checkpoint/savepoint 需要所有算子都处于 RUNNING 状态,不过社区也有一些 issue > > 希望能够优化这个问题[1][2] > > > > [1] https://issues.apache.org/jira/browse/FLINK-2491 > > [2] https://issues.apache.org/jira/browse/FLINK-18263 > > Best, > > Congxian > > > > > > yulu yang <[email protected]> 于2020年8月13日周四 下午1:49写道: > > > >> 请教大佬一个我最近在配置Flink流的过程中遇到问题, > >> > >> > flink作业中关联使用了物理表(字典表),在flinkjob启动后,会对字典表进行一次读取,然后该算子会变成FINISHED状态,导致该flinkjob无法保存checkpoint和savepoint。一般大家遇到这种问题都是怎么处理的,我这个作业在数据加工过程中必须用到字典表赋值。 > >> > > > -- 致 礼! 北京理正人信息技术有限公司 综合软件开发部: 杨豫鲁 TEL:13488824529
