我正在使用Flink1.7,并希望升级到1.10以支持模式演化。目前,我正在使用force kryo序列化程序进行状态序列化,而不向运算符提供任何uid。我是否有可能在没有uid的情况下处理flink1.7的保存点(使用状态处理器api)并将其嵌入到flink1.10中。我正在使用rocksdb状态后端。
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!