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
ng.html#testing-flink-jobs
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
used in my tests is ready, and Job
deployment is finished.
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html#testing-flink-jobs
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
