[Fix][Zeta] Increase the log level when waitForJobComplete fails (#6827)

apache · May 11, 2024 · 297f264 · 297f264
1 parent 329b849
commit 297f264
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/...el-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java b/...el-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java
@@ -101,14 +101,13 @@ public JobResult waitForJobCompleteV2() {
                             new RetryUtils.RetryMaterial(
                                     100000,
                                     true,
-                                    exception ->
-                                            ExceptionUtil.isOperationNeedRetryException(exception),
+                                    ExceptionUtil::isOperationNeedRetryException,
                                     Constant.OPERATION_RETRY_SLEEP));
             if (jobResult == null) {
                 throw new SeaTunnelEngineException("failed to fetch job result");
             }
         } catch (Exception e) {
-            LOGGER.info(
+            LOGGER.severe(
                     String.format(
                             "Job (%s) end with unknown state, and throw Exception: %s",
                             jobId, ExceptionUtils.getMessage(e)));

diff --git a/...server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/PendingCheckpoint.java b/...server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/PendingCheckpoint.java
@@ -153,7 +153,7 @@ public void acknowledgeTask(
     }
 
     protected boolean isFullyAcknowledged() {
-        return notYetAcknowledgedTasks.size() == 0;
+        return notYetAcknowledgedTasks.isEmpty();
     }
 
     private CompletedCheckpoint toCompletedCheckpoint() {