In that case you will have to query the REST API instead; you can
retrieve the address via MiniCluster#getRestAddress.
Something along these should work:
try (final RestClient restClient =
new RestClient(
RestClientConfiguration.fromConfiguration(new Configuration()),
E
Hi,
that helped however there is a problem with JobStatus. Please refer to [1]
In my case JobStatus is already Running but not all task are running.
Any idea how to get task status from MiniCluster?
[1]
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Issue-with-job-status-td
1)
You can either execute the job in a separate thread, or set
DeploymentOptions.ATTACHED to false in the MiniCluster configuration.
2)
The cluster not being ready is /usually/ not really an issue. I wouldn't
worry about it for the time being.
(The reason being that the MiniCluster resource alr
