You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/07/06 09:39:14 UTC
[flink] branch release-1.15 updated: [FLINK-26600][tests] Wait with savepoint until job is running
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 <ch...@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,