You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by hs...@apache.org on 2013/10/25 07:19:56 UTC
git commit: FLUME-2192. AbstractSinkProcessor stop incorrectly calls
start
Updated Branches:
refs/heads/trunk 603bcf2d0 -> f017ce5ac
FLUME-2192. AbstractSinkProcessor stop incorrectly calls start
(Jeremy Karlson via Hari Shreedharan)
Project: http://git-wip-us.apache.org/repos/asf/flume/repo
Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/f017ce5a
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/f017ce5a
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/f017ce5a
Branch: refs/heads/trunk
Commit: f017ce5aca00d280ad6ee94e63fe3b44c326c5cf
Parents: 603bcf2
Author: Hari Shreedharan <hs...@apache.org>
Authored: Thu Oct 24 22:18:37 2013 -0700
Committer: Hari Shreedharan <hs...@apache.org>
Committed: Thu Oct 24 22:18:37 2013 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flume/blob/f017ce5a/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java
----------------------------------------------------------------------
diff --git a/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java b/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java
index 528a309..1c30592 100644
--- a/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java
+++ b/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java
@@ -47,7 +47,7 @@ public abstract class AbstractSinkProcessor implements SinkProcessor {
@Override
public void stop() {
for(Sink s : sinkList) {
- s.start();
+ s.stop();
}
state = LifecycleState.STOP;
}