It appears, that queryable state access significantly changed in 1.4 compared to 1.3.

Documentation on the queryable state client https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/state/queryable_state.html#example
States that the client needs to connect to a proxy port.
My implementation, which I used for 1.3 is enclosed 

Attachment: ModelServingKeyedJob.scala
Description: Binary data


Here I am setting both server port and proxy port.
When I am running it on a localhost and try to do lsof -i:9069 and lsof -i:9067 It does not show anything using this port.

Am I missing something?

As a result my query implementation 

Attachment: ModelStateQuery.scala
Description: Binary data

  
Return an error - connection refused

My state is defined in the following class 

Attachment: DataProcessorKeyed.scala
Description: Binary data


Boris Lublinsky
FDP Architect
boris.lublin...@lightbend.com
https://www.lightbend.com/

Reply via email to