Repository: helix
Updated Branches:
  refs/heads/master 2049f93ab -> a9cdecc64


Fix log output.


Project: http://git-wip-us.apache.org/repos/asf/helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/a9cdecc6
Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/a9cdecc6
Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/a9cdecc6

Branch: refs/heads/master
Commit: a9cdecc644608725e4f561da23e3976226b44430
Parents: a979f35
Author: Lei Xia <[email protected]>
Authored: Thu May 24 14:28:21 2018 -0700
Committer: Junkai Xue <[email protected]>
Committed: Mon Jul 9 15:56:40 2018 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/helix/common/DedupEventProcessor.java | 2 +-
 .../main/java/org/apache/helix/messaging/handling/HelixTask.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/helix/blob/a9cdecc6/helix-core/src/main/java/org/apache/helix/common/DedupEventProcessor.java
----------------------------------------------------------------------
diff --git 
a/helix-core/src/main/java/org/apache/helix/common/DedupEventProcessor.java 
b/helix-core/src/main/java/org/apache/helix/common/DedupEventProcessor.java
index 942b021..10e3b00 100644
--- a/helix-core/src/main/java/org/apache/helix/common/DedupEventProcessor.java
+++ b/helix-core/src/main/java/org/apache/helix/common/DedupEventProcessor.java
@@ -49,7 +49,7 @@ public abstract class DedupEventProcessor<T, E> extends 
Thread {
       } catch (ThreadDeath death) {
         throw death;
       } catch (Throwable t) {
-        logger.error(_processorName + " thread failed while running the 
controller pipeline", t);
+        logger.error(_processorName + " thread failed while running " + 
_processorName, t);
       }
     }
     logger.info("END " + _processorName + " thread for cluster " + 
_clusterName);

http://git-wip-us.apache.org/repos/asf/helix/blob/a9cdecc6/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTask.java
----------------------------------------------------------------------
diff --git 
a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTask.java 
b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTask.java
index 3cca883..0738ef9 100644
--- 
a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTask.java
+++ 
b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTask.java
@@ -255,7 +255,7 @@ public class HelixTask implements MessageTask {
           if (!success) {
             logger.warn("Failed to send relay message " + msg.getId() + " to " 
+ instance);
           } else {
-            logger.info("Send relay message " + message.getId() + " to " + 
instance);
+            logger.info("Send relay message " + msg.getId() + " to " + 
instance);
           }
         }
       }

Reply via email to