code style

TongchengOpenSource · Apr 1, 2024 · b063d56 · b063d56
1 parent 202a21f
commit b063d56
Showing 1 changed file with 7 additions and 9 deletions.
diff --git a/...unnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java b/...unnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
@@ -254,15 +254,13 @@ public boolean taskIsEnded(@NonNull TaskGroupLocation taskGroupLocation) {
     public boolean isMasterNode() {
         // must retry until the cluster have master node
         try {
-            return Boolean.TRUE.equals(
-                    RetryUtils.retryWithException(
-                            () -> nodeEngine.getThisAddress().equals(nodeEngine.getMasterAddress()),
-                            new RetryUtils.RetryMaterial(
-                                    Constant.OPERATION_RETRY_TIME,
-                                    true,
-                                    exception ->
-                                            exception instanceof NullPointerException && isRunning,
-                                    Constant.OPERATION_RETRY_SLEEP)));
+            return RetryUtils.retryWithException(
+                    () -> nodeEngine.getThisAddress().equals(nodeEngine.getMasterAddress()),
+                    new RetryUtils.RetryMaterial(
+                            Constant.OPERATION_RETRY_TIME,
+                            true,
+                            exception -> exception instanceof NullPointerException && isRunning,
+                            Constant.OPERATION_RETRY_SLEEP));
         } catch (InterruptedException e) {
             LOGGER.info("master node check interrupted");
             return false;