This method should be called `waitForJobRunning()`; however this entire logic can be implemented more nicely with a [BlockerSync](https://github.com/apache/flink/blob/master/flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/BlockerSync.java) anyway. The UDF would wait until the test thread calls `block`, and then you reverse this for unblocking the thread.
This method could then be removed. [ Full content available at: https://github.com/apache/flink/pull/6702 ] This message was relayed via gitbox.apache.org for [email protected]
