flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arv...@apache.org
Subject svn commit: r1308548 - in /incubator/flume/trunk: flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
Date Mon, 02 Apr 2012 20:50:39 GMT
Author: arvind
Date: Mon Apr  2 20:50:38 2012
New Revision: 1308548

URL: http://svn.apache.org/viewvc?rev=1308548&view=rev
Log:
FLUME-1090. JDBC Channel - Minimize logging under nominal conditions.

(Mike Percy via Arvind Prabhakar)

Modified:
    incubator/flume/trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java
    incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java

Modified: incubator/flume/trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java?rev=1308548&r1=1308547&r2=1308548&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java
(original)
+++ incubator/flume/trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java
Mon Apr  2 20:50:38 2012
@@ -128,7 +128,7 @@ public class JdbcChannelProviderImpl imp
 
     if (maxCapacitySpecified > 0) {
       this.maxCapacity = maxCapacitySpecified;
-      LOGGER.debug("Maximum channel capacity: " + maxCapacity);
+      LOGGER.info("Maximum channel capacity: {}", maxCapacity);
     } else {
       LOGGER.warn("JDBC channel will operate without a capacity limit.");
     }
@@ -156,7 +156,7 @@ public class JdbcChannelProviderImpl imp
 
       boolean createIndex = Boolean.valueOf(createIndexFlag);
       if (!createIndex) {
-        LOGGER.info("Index creation is disabled, indexes will not be created.");
+        LOGGER.warn("Index creation is disabled, indexes will not be created.");
       }
 
       // Now create schema
@@ -247,7 +247,7 @@ public class JdbcChannelProviderImpl imp
       }
     }
 
-    LOGGER.info("Persistend event: " + persistableEvent.getEventId());
+    LOGGER.debug("Persisted event: {}", persistableEvent.getEventId());
   }
 
   @Override
@@ -273,9 +273,9 @@ public class JdbcChannelProviderImpl imp
     }
 
     if (result != null) {
-      LOGGER.info("Removed event: " + ((PersistableEvent) result).getEventId());
+      LOGGER.debug("Removed event: {}", ((PersistableEvent) result).getEventId());
     } else {
-      LOGGER.info("No event found for removal");
+      LOGGER.warn("No event found for removal");
     }
 
     return result;

Modified: incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java?rev=1308548&r1=1308547&r2=1308548&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
(original)
+++ incubator/flume/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
Mon Apr  2 20:50:38 2012
@@ -97,7 +97,7 @@ public class NullSink extends AbstractSi
 
     super.stop();
 
-    logger.debug("Null sink stopped. Event metrics:{}", counterGroup);
+    logger.info("Null sink stopped. Event metrics:{}", counterGroup);
   }
 
 }



Mime
View raw message