You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by es...@apache.org on 2011/08/12 02:48:37 UTC
svn commit: r1156912 - in /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume: sink/DefaultSinkFactory.java source/DefaultSourceFactory.java

Author: esammer
Date: Fri Aug 12 00:48:37 2011
New Revision: 1156912

URL: http://svn.apache.org/viewvc?rev=1156912&view=rev
Log:
- Adjusted logging levels of source / sink factories.

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java?rev=1156912&r1=1156911&r2=1156912&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java Fri Aug 12 00:48:37 2011
@@ -24,7 +24,7 @@ public class DefaultSinkFactory implemen
 
   @Override
   public boolean register(String name, Class<? extends EventSink> sinkClass) {
-    logger.info("Register sink class:{}", sinkClass);
+    logger.info("Register sink name:{} class:{}", name, sinkClass);
 
     if (sinkRegistry.containsKey(name)) {
       return false;
@@ -50,7 +50,7 @@ public class DefaultSinkFactory implemen
   public EventSink create(String name) throws InstantiationException {
     Preconditions.checkNotNull(name);
 
-    logger.info("Creating instance of source {}", name);
+    logger.debug("Creating instance of source {}", name);
 
     if (!sinkRegistry.containsKey(name)) {
       return null;

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java?rev=1156912&r1=1156911&r2=1156912&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java Fri Aug 12 00:48:37 2011
@@ -24,7 +24,7 @@ public class DefaultSourceFactory implem
 
   @Override
   public boolean register(String name, Class<? extends EventSource> sourceClass) {
-    logger.info("Register source class:{}", sourceClass);
+    logger.info("Register source name:{} class:{}", name, sourceClass);
 
     if (sourceRegistry.containsKey(name)) {
       return false;
@@ -50,7 +50,7 @@ public class DefaultSourceFactory implem
   public EventSource create(String name) throws InstantiationException {
     Preconditions.checkNotNull(name);
 
-    logger.info("Creating instance of source {}", name);
+    logger.debug("Creating instance of source {}", name);
 
     if (!sourceRegistry.containsKey(name)) {
       return null;