flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From esam...@apache.org
Subject svn commit: r1165712 - /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/PollableSinkRunner.java
Date Tue, 06 Sep 2011 15:22:43 GMT
Author: esammer
Date: Tue Sep  6 15:22:43 2011
New Revision: 1165712

URL: http://svn.apache.org/viewvc?rev=1165712&view=rev
Log:
- Fixed a bug where we didn't start the sink in a PollingSinkRunner.

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

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/PollableSinkRunner.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/PollableSinkRunner.java?rev=1165712&r1=1165711&r2=1165712&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/PollableSinkRunner.java
(original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/PollableSinkRunner.java
Tue Sep  6 15:22:43 2011
@@ -29,6 +29,9 @@ public class PollableSinkRunner extends 
 
   @Override
   public void start() {
+
+    sink.start();
+
     runner = new PollingRunner();
 
     runner.sink = sink;
@@ -44,6 +47,8 @@ public class PollableSinkRunner extends 
   @Override
   public void stop() {
 
+    sink.stop();
+
     if (runnerThread != null) {
       runner.shouldStop.set(true);
       runnerThread.interrupt();



Mime
View raw message