storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/3] storm git commit: STORM-2032 removes warning in case more than one metrics tuple is received
Date Fri, 12 Aug 2016 01:40:07 GMT
Repository: storm
Updated Branches:
  refs/heads/1.0.x-branch e104f9f37 -> c24179c3d


STORM-2032 removes warning in case more than one metrics tuple is received

* changes level of potentially confusing log message to DEBUG
* Closes #1618


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

Branch: refs/heads/1.0.x-branch
Commit: d8c6e288529284744fa95321b483c965551039ce
Parents: e104f9f
Author: Derek Dagit <derekd@yahoo-inc.com>
Authored: Thu Aug 11 09:24:59 2016 -0500
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Fri Aug 12 10:39:04 2016 +0900

----------------------------------------------------------------------
 .../jvm/org/apache/storm/messaging/netty/StormClientHandler.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/d8c6e288/storm-core/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java b/storm-core/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java
index 65c4b02..e763d5d 100644
--- a/storm-core/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java
+++ b/storm-core/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java
@@ -60,7 +60,7 @@ public class StormClientHandler extends SimpleChannelUpstreamHandler  {
                 //This should be the metrics, and there should only be one of them
                 List<TaskMessage> list = (List<TaskMessage>)message;
                 if (list.size() < 1) throw new RuntimeException("Didn't see enough load
metrics ("+client.getDstAddress()+") "+list);
-                if (list.size() != 1) LOG.warn("Messages are not being delivered fast enough,
got "+list.size()+" metrics messages at once("+client.getDstAddress()+")");
+                if (list.size() != 1) LOG.debug("Messages are not being delivered fast enough,
got "+list.size()+" metrics messages at once("+client.getDstAddress()+")");
                 TaskMessage tm = ((List<TaskMessage>)message).get(list.size() - 1);
                 if (tm.task() != -1) throw new RuntimeException("Metrics messages are sent
to the system task ("+client.getDstAddress()+") "+tm);
                 List metrics = _des.deserialize(tm.message());


Mime
View raw message