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。一般大家遇到这种问题都是怎么处理的，我这个作业在数据加工过程中必须用到字典表赋值。 >> >
