Fix test failure

Author: yunfengzhou-hub

paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FlinkChainTableITCase.java

@@ -1476,19 +1476,24 @@ private String triggerCheckpoint(JobClient jobClient) throws Exception {
         while (!allRunning.get()) {
             allRunning.set(true);
             Thread.sleep(1000);
-            miniCluster
-                    .getExecutionGraph(jobID)
-                    .thenAccept(
-                            eg ->
-                                    eg.getAllExecutionVertices()
-                                            .forEach(
-                                                    v -> {
-                                                        if (v.getExecutionState()
-                                                                != ExecutionState.RUNNING) {
-                                                            allRunning.set(false);
-                                                        }
-                                                    }))
-                    .get();
+            try {
+                miniCluster
+                        .getExecutionGraph(jobID)
+                        .thenAccept(
+                                eg ->
+                                        eg.getAllExecutionVertices()
+                                                .forEach(
+                                                        v -> {
+                                                            if (v.getExecutionState()
+                                                                    != ExecutionState.RUNNING) {
+                                                                allRunning.set(false);
+                                                            }
+                                                        }))
+                        .get();
+            } catch (Exception e) {
+                // Job not yet available — retry
+                allRunning.set(false);
+            }
         }
 
         return miniCluster.triggerCheckpoint(jobID).get();