You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/08/12 01:40:07 UTC
[1/3] storm git commit: STORM-2032 removes warning in case more than
one metrics tuple is received
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 <de...@yahoo-inc.com>
Authored: Thu Aug 11 09:24:59 2016 -0500
Committer: Jungtaek Lim <ka...@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());
[3/3] storm git commit: add STORM-2032 to CHANGELOG
Posted by ka...@apache.org.
add STORM-2032 to CHANGELOG
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c24179c3
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c24179c3
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c24179c3
Branch: refs/heads/1.0.x-branch
Commit: c24179c3da3ffc18e82c87bf12dd6ae445a429ce
Parents: 93e62f0
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Fri Aug 12 10:39:54 2016 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Fri Aug 12 10:39:54 2016 +0900
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/c24179c3/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 7b8f0ea..99cead4 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 1.0.3
+ * STORM-2032: removes warning in case more than one metrics tuple is received
* STORM-1594: org.apache.storm.tuple.Fields can throw NPE if given invalid field in selector
* STORM-1995: downloadChunk in nimbus.clj should close the input stream
[2/3] storm git commit: Merge branch 'STORM-2032-1.0.x' into
1.0.x-branch
Posted by ka...@apache.org.
Merge branch 'STORM-2032-1.0.x' into 1.0.x-branch
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/93e62f08
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/93e62f08
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/93e62f08
Branch: refs/heads/1.0.x-branch
Commit: 93e62f0849b752d5cef766b03b56897f675dbc47
Parents: e104f9f d8c6e28
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Fri Aug 12 10:39:23 2016 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Fri Aug 12 10:39:23 2016 +0900
----------------------------------------------------------------------
.../jvm/org/apache/storm/messaging/netty/StormClientHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------