Re: State Processor API SQL State

[Yun Tang]

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 <[hidden email]>
Sent: Tuesday, December 1, 2020 21:05
To: dev <[hidden email]>
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.