Re: Can't find correct JobManager address, job fails with Queryable state

Thanks Aljoscha, this clarification probably ends my search of accessing local states from within the same job. Thanks for the help :) -- View this message in context:

Re: Can't find correct JobManager address, job fails with Queryable state

Hi, I'm afraid you are running into roughly this problem: https://issues.apache.org/jira/browse/FLINK-6689 It's not possible anymore to connect to a LocalFlinkMiniCluster, either via a RemoteExecutionEnvironment or via the queryable state

Re: Can't find correct JobManager address, job fails with Queryable state

Hi Nico, I had actually tried doing that but I still get the same error as before with the actor not found. I then ran on my mock cluster and I was getting the same error although I could observe the jobmanager on the yarn cluster mode with a defined port. The addres and port combination was

Re: Can't find correct JobManager address, job fails with Queryable state

Hi Biplob, by starting a local environment the way you described, i.e. by using LocalStreamEnvironment.createLocalEnvironmentWithWebUI(conf); you are firing up a LocalFlinkMiniCluster which, by default, has the queryable state server disabled. You can enable it via:

Re: Can't find correct JobManager address, job fails with Queryable state

I managed to get the Web UI up and running but I am still getting the error with "Actor not found" Before the job failed I got the output for the Flink config from the WebUI and it seems okay to me, this corresponds to the config I have already set.