Hey, Thanks a lot for that. Best Regards, Dom. śr., 2 gru 2020 o 03:45 Yun Tang <myas...@live.com> napisał(a):
> Hi Dom, > > + user mail list > > Once you got to know the state descriptor, I think you could query the > join state. The state name is easy to get via [1], it should be > "left-records" and "right-records", and you could check what kind of join > and whether has unique key to decide what kind of state (value state or map > state). The last part is to find what the rowData type is in your join, and > maybe other SQL guys could answer this or you might find it by yourself by > dumping the memory of your taskmanager. > > [1] > https://github.com/apache/flink/blob/7a7c87096ab76f416cd7c393240faa8454db36f0/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 <wos...@gmail.com> > Sent: Tuesday, December 1, 2020 21:05 > To: dev <dev@flink.apache.org> > Subject: State Processor API SQL State > > 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. >
