[flink] branch master updated: [FLINK-26323][tests] Allow CREATED state

[ch...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 78a96a4b1e8 [FLINK-26323][tests] Allow CREATED state
78a96a4b1e8 is described below

commit 78a96a4b1e863ecaf33882773c985678821bef81
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Jul 5 11:30:59 2022 +0200

    [FLINK-26323][tests] Allow CREATED state
---
 .../apache/flink/client/program/PerJobMiniClusterFactoryTest.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 2257839f0ef..082712ee559 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
@@ -37,6 +37,7 @@ import java.util.Map;
 import java.util.concurrent.ExecutionException;
 
 import static org.apache.flink.core.testutils.CommonTestUtils.assertThrows;
+import static org.hamcrest.CoreMatchers.anyOf;
 import static org.hamcrest.CoreMatchers.is;
 import static org.hamcrest.CoreMatchers.notNullValue;
 import static org.hamcrest.MatcherAssert.assertThat;
@@ -82,7 +83,9 @@ public class PerJobMiniClusterFactoryTest extends TestLogger {
                         .get();
 
         assertThat(jobClient.getJobID(), is(cancellableJobGraph.getJobID()));
-        assertThat(jobClient.getJobStatus().get(), is(JobStatus.RUNNING));
+        assertThat(
+                jobClient.getJobStatus().get(),
+                anyOf(is(JobStatus.CREATED), is(JobStatus.RUNNING)));
 
         jobClient.cancel().get();