From 98d4e1f5f262a440beb9bc7cc92d53cb8a6f690b Mon Sep 17 00:00:00 2001
From: baoliang <baoliang@analysys.com.cn>
Date: Tue, 10 Nov 2020 15:30:51 +0800
Subject: [PATCH] refactor

---
 .../server/worker/processor/TaskCallbackService.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 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
index 7a21f7ece2..eda4da6dd9 100644
--- 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()) {