[fix] No need to cancel job again

apache · Dec 4, 2024 · c443257 · c443257
1 parent 0baa838
commit c443257
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...on-flink-common/src/test/java/org/apache/paimon/flink/PrimaryKeyFileStoreTableITCase.java b/...on-flink-common/src/test/java/org/apache/paimon/flink/PrimaryKeyFileStoreTableITCase.java
@@ -110,7 +110,7 @@ private CloseableIterator<Row> collect(TableResult result, int timeout) {
                                 try {
                                     Thread.sleep(1000);
                                     if (client.getJobStatus().get().isGloballyTerminalState()) {
-                                        break;
+                                        return;
                                     }
                                 } catch (Exception e) {
                                     client.cancel();