flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From esam...@apache.org
Subject svn commit: r1156912 - in /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume: sink/DefaultSinkFactory.java source/DefaultSourceFactory.java
Date Fri, 12 Aug 2011 00:48:37 GMT
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;



Mime
View raw message