可以，保证 RokcetMQ source 算子的 uid 和原本的 Kafka source 算子的 uid 不同就行。 另外启动要设置参数 -n 或 —allowNonRestoredState 。
Best, Paul Lam > 2020年9月2日 17:21，wangl...@geekplus.com 写道： > > > 有一个 flink streaming 的程序，读 RocketMQ，中间有一些复杂度计算逻辑用 RocksDB state 存储. > 程序有小的更新直接 cancel -s 取消再 run -s 恢复 > > 现在我们需要用 Kafka 替换掉 RocketMQ，消息内容都是一样的， flink 程序需要改一下改为读 Kafka > 我可以直接 cancel -s 后再 run -s 复用之前的 state 吗？ > > > > > > wangl...@geekplus.com
