Get side output (events where join didn't succeed) for IntervalJoin

Hi, I'm exploring Interval Join as a probable solution for joins between two streams of data, with a long lookback period. While going through the official documentation, I couldn't figure out

Re: Externally load data into RocksDB backend

I believe you're trying to bootstrap state for an operator. If yes, then it might be worthwhile to check out State Processor API

Re: Transition Flink job from Java to Scala with state migration

[2] > https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html > <https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/state/schema_evolution.html> > > On Tue, Aug 25, 2020 at 4:43 PM Daksh Talwar > wrote: > >&g

Transition Flink job from Java to Scala with state migration

Hello, We run a Stream API based Flink application on 1.10.0, coded in Java. While moving this job to Scala (reasons unrelated to Flink/this application), we are getting the following error when trying to instantiate Scala job from a savepoint taken in the Java job: *org.apache.flink.util.StateMi