[flink-table-store] branch master updated: [FLINK-29075] Fix table store unstable test RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new f3b1e813 [FLINK-29075] Fix table store unstable test 
RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite
f3b1e813 is described below

commit f3b1e813684194fa50d57663fea2f06d747f5f96
Author: tsreaper <tsreape...@gmail.com>
AuthorDate: Thu Oct 27 11:55:06 2022 +0800

    [FLINK-29075] Fix table store unstable test 
RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite
    
    This closes #335
---
 .../org/apache/flink/table/store/connector/RescaleBucketITCase.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/RescaleBucketITCase.java
 
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/RescaleBucketITCase.java
index d3efcf5f..a14ba63b 100644
--- 
a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/RescaleBucketITCase.java
+++ 
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/RescaleBucketITCase.java
@@ -19,7 +19,6 @@
 package org.apache.flink.table.store.connector;
 
 import org.apache.flink.api.common.JobID;
-import org.apache.flink.api.common.JobStatus;
 import org.apache.flink.client.program.ClusterClient;
 import org.apache.flink.core.execution.SavepointFormatType;
 import org.apache.flink.runtime.jobgraph.SavepointConfigOptions;
@@ -154,7 +153,7 @@ public class RescaleBucketITCase extends 
FileStoreTableITCase {
     private void stopJobSafely(ClusterClient<?> client, JobID jobId)
             throws ExecutionException, InterruptedException {
         client.stopWithSavepoint(jobId, true, path, 
SavepointFormatType.DEFAULT);
-        while (client.getJobStatus(jobId).get() == JobStatus.RUNNING) {
+        while (!client.getJobStatus(jobId).get().isGloballyTerminalState()) {
             Thread.sleep(2000L);
         }
     }