Re: Question about to modify operator state on Flink1.7 with State Processor API

2019-11-26 Thread Kaihao Zhao
this kind of non-UID case easier. Best, Kaihao Zhao On Tue, Nov 26, 2019 at 10:29 AM Seth Wiesman wrote: > The state proc api makes the same guarantees around savepoint > compatibility as the rest of Flink. It is backwards compatible up to 3 > versions but there are no guarantees around

Question about to modify operator state on Flink1.7 with State Processor API

2019-11-25 Thread Kaihao Zhao
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