[flink] branch release-1.15 updated: [FLINK-26600][tests] Wait with savepoint until job is running

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.15 by this push:
     new d0b181e4990 [FLINK-26600][tests] Wait with savepoint until job is 
running
d0b181e4990 is described below

commit d0b181e49907427e53a0db817741e75d29461c30
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Tue Jul 5 10:08:26 2022 +0200

    [FLINK-26600][tests] Wait with savepoint until job is running
---
 .../org/apache/flink/client/program/PerJobMiniClusterFactoryTest.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/flink-clients/src/test/java/org/apache/flink/client/program/PerJobMiniClusterFactoryTest.java
 
b/flink-clients/src/test/java/org/apache/flink/client/program/PerJobMiniClusterFactoryTest.java
index 082712ee559..9a91979d7d4 100644
--- 
a/flink-clients/src/test/java/org/apache/flink/client/program/PerJobMiniClusterFactoryTest.java
+++ 
b/flink-clients/src/test/java/org/apache/flink/client/program/PerJobMiniClusterFactoryTest.java
@@ -105,6 +105,10 @@ public class PerJobMiniClusterFactoryTest extends 
TestLogger {
                         .submitJob(getCancellableJobGraph(), 
ClassLoader.getSystemClassLoader())
                         .get();
 
+        while (jobClient.getJobStatus().get() != JobStatus.RUNNING) {
+            Thread.sleep(50);
+        }
+
         assertThrows(
                 "is not a streaming job.",
                 ExecutionException.class,