refactor

4 years ago · 98d4e1f5f2
1 changed files with 4 additions and 4 deletions
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackService.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackService.java
@ -96,11 +96,11 @@ public class TaskCallbackService {
            if(newChannel != null){
                return getRemoteChannel(newChannel, nettyRemoteChannel.getOpaque(), taskInstanceId);
            }
-
+            logger.warn("original master : {} for task : {} is not reachable, random select master",
+                    nettyRemoteChannel.getHost(),
+                    taskInstanceId);
        }
-        logger.warn("original master : {} for task : {} is not reachable, random select master",
-                nettyRemoteChannel.getHost(),
-                taskInstanceId);
+
        Set<String> masterNodes = null;
        int ntries = 0;
        while (Stopper.isRunning()) {