[Fix][Zeta] Increase the log level when waitForJobComplete fails (#6827)
diff --git a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java
index 21802c5..bcb1dd8 100644
--- a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java
+++ b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java
@@ -101,14 +101,13 @@
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/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/PendingCheckpoint.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/PendingCheckpoint.java
index 1d92096..4b35f3f 100644
--- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/PendingCheckpoint.java
+++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/PendingCheckpoint.java
@@ -153,7 +153,7 @@
}
protected boolean isFullyAcknowledged() {
- return notYetAcknowledgedTasks.size() == 0;
+ return notYetAcknowledgedTasks.isEmpty();
}
private CompletedCheckpoint toCompletedCheckpoint() {
