cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r1002329 - /cassandra/trunk/src/java/org/apache/cassandra/streaming/StreamOutSession.java
Date Tue, 28 Sep 2010 19:22:29 GMT
Author: jbellis
Date: Tue Sep 28 19:22:29 2010
New Revision: 1002329

URL: http://svn.apache.org/viewvc?rev=1002329&view=rev
Log:
move the bulk of streaming diagnostic message from INFO to DEBUG.  patch by jbellis

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/streaming/StreamOutSession.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/streaming/StreamOutSession.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/streaming/StreamOutSession.java?rev=1002329&r1=1002328&r2=1002329&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/streaming/StreamOutSession.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/streaming/StreamOutSession.java Tue Sep
28 19:22:29 2010
@@ -172,7 +172,8 @@ public class StreamOutSession
         PendingFile first = files.isEmpty() ? null : files.values().iterator().next();
         currentFile = first == null ? null : first.getFilename();
         StreamHeader header = new StreamHeader(table, getSessionId(), first, files.values());
-        logger.info("Streaming files {} to {}", StringUtils.join(files.values(), ","), getHost());
+        logger.info("Streaming to {}", getHost());
+        logger.debug("Files are {}", StringUtils.join(files.values(), ","));
         MessagingService.instance.stream(header, getHost());
     }
 }



Mime
View raw message