Fix flink getJobStatus bug

ChengJie1053 · Dec 13, 2023 · d914fbd · d914fbd
1 parent d4dc8af
commit d914fbd
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/.../org/apache/linkis/engineconnplugin/flink/client/deployment/ClusterDescriptorAdapter.java b/.../org/apache/linkis/engineconnplugin/flink/client/deployment/ClusterDescriptorAdapter.java
@@ -91,6 +91,15 @@ public ClusterDescriptorAdapter(ExecutionContext executionContext) {
 
   /** Returns the status of the flink job. */
   public JobStatus getJobStatus() throws JobExecutionException {
+    if (jobId == null) {
+      try {
+        LOG.info("flink getJobStatus jobId is null,sleep three seconds");
+        Thread.sleep(3000);
+      } catch (InterruptedException e) {
+
+      }
+    }
+    LOG.info("flink getJobStatus jobId:{}", jobId);
     if (jobId == null) {
       throw new JobExecutionException(NO_JOB_SUBMITTED.getErrorDesc());
     }