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/19 20:10:38 UTC
svn commit: r1159725 -
/incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
Author: esammer
Date: Fri Aug 19 18:10:37 2011
New Revision: 1159725
URL: http://svn.apache.org/viewvc?rev=1159725&view=rev
Log:
- Added registration of RollingFileSink
Modified:
incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
Modified: incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java?rev=1159725&r1=1159724&r2=1159725&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/main/java/org/apache/flume/node/Application.java Fri Aug 19 18:10:37 2011
@@ -20,6 +20,7 @@ import org.apache.flume.node.nodemanager
import org.apache.flume.sink.DefaultSinkFactory;
import org.apache.flume.sink.LoggerSink;
import org.apache.flume.sink.NullSink;
+import org.apache.flume.sink.RollingFileSink;
import org.apache.flume.source.DefaultSourceFactory;
import org.apache.flume.source.NetcatSource;
import org.apache.flume.source.SequenceGeneratorSource;
@@ -65,6 +66,7 @@ public class Application {
sinkFactory.register("null", NullSink.class);
sinkFactory.register("logger", LoggerSink.class);
+ sinkFactory.register("file-roll", RollingFileSink.class);
}
public void parseOptions() throws ParseException {
@@ -117,11 +119,10 @@ public class Application {
try {
node.stop(context);
} catch (LifecycleException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
+ logger.error("Unable to stop node. Exception follows.", e);
} catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
+ logger
+ .error("Interrupted while stopping node. Exception follows.", e);
}
}