You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/02/23 22:11:31 UTC
[4/6] storm git commit: Change log level for intentionally dropping
messages from WARN to ERROR
Change log level for intentionally dropping messages from WARN to ERROR
This change makes the log level for dropping messages consistent in
Client.java.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/522d96e5
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/522d96e5
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/522d96e5
Branch: refs/heads/master
Commit: 522d96e5953037728422935d31401a58e943c688
Parents: 0061343
Author: Michael G. Noll <mn...@verisign.com>
Authored: Mon Feb 16 10:07:35 2015 +0100
Committer: Michael G. Noll <mn...@verisign.com>
Committed: Mon Feb 16 10:07:35 2015 +0100
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/522d96e5/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
index 189fa95..7392d3e 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -358,7 +358,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
public synchronized void send(Iterator<TaskMessage> msgs) {
if (closing) {
int numMessages = iteratorSize(msgs);
- LOG.warn("discarding {} messages because the Netty client to {} is being closed", numMessages,
+ LOG.error("discarding {} messages because the Netty client to {} is being closed", numMessages,
dstAddressPrefixedName);
return;
}
@@ -475,7 +475,7 @@ public class Client extends ConnectionWithStatus implements IStatefulObject {
messagesSent.getAndAdd(batch.size());
}
else {
- LOG.warn("failed to send {} messages to {}: {}", numMessages, dstAddressPrefixedName,
+ LOG.error("failed to send {} messages to {}: {}", numMessages, dstAddressPrefixedName,
future.getCause());
closeChannelAndReconnect(future.getChannel());
messagesLost.getAndAdd(numMessages);