flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Biplob Biswas <revolutioni...@gmail.com>
Subject Re: Getting JobManager address and port within a running job
Date Wed, 09 Aug 2017 12:33:39 GMT
Hi Aljoscha,

I was expecting that I could set the jobmanager address and port by setting
it up in the configuration and passing it to the execution environment, but
learnt later that it was a wrong approach. 

My motivation of accessing the jobmanager coordinates was to setup a
queryablestateclient such that I could query the states I created in the
same job.  
My job wants me to have 2 states and query based on specific keys on both
the states at the same time, so I couldn't imagine achieving this within the
same operator as states are created and updated pe key.

is there any abstraction which exposes these values for jobmanager? 

For now what I did to achieve what I want is to create 2 states in one flink
job and passed the job id and jobmanager information as parameters to the
second job which queries the states. 

is there a better way to do this? 

thanks & regards,

View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Getting-JobManager-address-and-port-within-a-running-job-tp14656p14759.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

View raw message