From c4432578cebcbefafae52a561d14ccab5d4dab43 Mon Sep 17 00:00:00 2001
From: tsreaper <tsreaper96@gmail.com>
Date: Wed, 4 Dec 2024 14:55:05 +0800
Subject: [PATCH] [fix] No need to cancel job again

---
 .../org/apache/paimon/flink/PrimaryKeyFileStoreTableITCase.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PrimaryKeyFileStoreTableITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PrimaryKeyFileStoreTableITCase.java
index 486ea45a6260..4ee539c4fd27 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PrimaryKeyFileStoreTableITCase.java
+++ b/paimon-flink/paimon-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();