Hi Vino/Seth,
Thanks Vino and Seth, changing the UID and setting offset manually is a
solution, but the pin point is we have tons of applications(owned by other
users) running on our platform, so it will be inefficient to do it
manually, and the most difficult part is to let users to change their
Hi Kaihao,
Ping @Aljoscha Krettek @Tzu-Li (Gordon) Tai
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 于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 whe