Re: State Processor API SQL State

2020-12-02 Thread Dominik Wosiński
join/stream/StreamingJoinOperator.java#L83 > > Best > Yun Tang > > > > > From: Dominik Wosiński > Sent: Tuesday, December 1, 2020 21:05 > To: dev > Subject: State Processor API SQL State > > Hey, > Is it currently possible to obtain the state that was create

Re: State Processor API SQL State

2020-12-01 Thread Yun Tang
0faa8454db36f0/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.java#L83 Best Yun Tang From: Dominik Wosiński Sent: Tuesday, December 1, 2020 21:05 To: dev Subject: State Processor AP

State Processor API SQL State

2020-12-01 Thread Dominik Wosiński
Hey, Is it currently possible to obtain the state that was created by SQL query via the State Processor API? I am able to load the checkpoint via the State Processor API, but I wasn't able to think of a way to access the internal state of my JOIN Query. Best Regards, Dom.