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 <[email protected]> Authored: Mon Feb 16 10:07:35 2015 +0100 Committer: Michael G. Noll <[email protected]> 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);
