Unsubscribe

Unsubscribe

Fail to recover Keyed State afeter ReinterpretAsKeyedStream

Hi, To avoid reshuffling in my job, I started using DataStreamUtils. reinterpretAsKeyedStream to avoid having to do another keyBy for the same key. The BackEndState is RocksDB. When the job recovers after a failure, the ProcessFunction after the keyBy restores its Keyed State correctly, while