Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r176688158 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -80,42 +95,38 @@ public void testJobRetrieval() throws Exception { final JobGraph jobGraph = new JobGraph(jobID, "testjob", imalock); - final ClusterClient<StandaloneClusterId> client = new StandaloneClusterClient(cluster.configuration(), cluster.highAvailabilityServices(), true); - // acquire the lock to make sure that the job cannot complete until the job client // has been attached in resumingThread lock.acquire(); --- End diff -- That would no longer verify that you can connect to a _running_ job though.
---