Hi Kaihao, Ping @Aljoscha Krettek <aljos...@apache.org> @Tzu-Li (Gordon) Tai <tzuli...@apache.org> to give more professional suggestions.
What's more, we may need to give a statement about if the state processor API can process the snapshots generated by the old version jobs. WDYT? Best, Vino Kaihao Zhao <zhaokai...@gmail.com> 于2019年11月25日周一 下午11:39写道： > Hi, > > We are running Flink 1.7 and recently due to Kafka cluster migration, we > need to find a way to modify kafka offset in FlinkKafkaConnector's state, > and we found Flink 1.9's State Processor API is the exactly tool we need, > we are able to modify the operator state via State Processor API, but when > trying to resume App from the modified savepoint, we found it failed with > ClassNotFoundException: *TupleSerializerSnapshot*, these > *TypeSerializerSnapshots* are new in Flink 1.9 but not in 1.7, so I > wonder if there has any suggestion or workaround to modify 1.7's state? > > -- > Thanks & Regards > Zhao Kaihao >
