debug message removed

smtp2006 · May 10, 2013 · cbd9d1e · cbd9d1e
1 parent 89e8c66
commit cbd9d1e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/storm-netty/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-netty/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -84,7 +84,7 @@ void reconnect() {
                 close();
             }
         } catch (InterruptedException e) {
-            LOG.info("connection failed", e);
+            LOG.warn("connection failed", e);
         } 
     }
 
@@ -157,7 +157,7 @@ public void close() {
             @Override
             public void run() {
                 if (ready_to_release_resource.get()) {
-                    LOG.info("client resource released");
+                    LOG.debug("client resource released");
                     factory.releaseExternalResources();
                     timer.cancel();
                 }

diff --git a/storm-netty/src/jvm/backtype/storm/messaging/netty/MessageDecoder.java b/storm-netty/src/jvm/backtype/storm/messaging/netty/MessageDecoder.java
@@ -9,8 +9,6 @@
 import backtype.storm.messaging.TaskMessage;
 
 public class MessageDecoder extends FrameDecoder {    
-    private static final Logger LOG = LoggerFactory.getLogger(MessageDecoder.class);
-
     /*
      * Each ControlMessage is encoded as:
      *  code (<0) ... short(2)