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.
