Updated Branches: refs/heads/flume-1.5 933617039 -> 9b9c0831e
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/9b9c0831 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/9b9c0831 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/9b9c0831 Branch: refs/heads/flume-1.5 Commit: 9b9c0831ee15afe118e5ab53872ea52989fa4275 Parents: 9336170 Author: Hari Shreedharan <hshreedha...@apache.org> Authored: Thu Oct 24 22:18:37 2013 -0700 Committer: Hari Shreedharan <hshreedha...@apache.org> Committed: Thu Oct 24 22:19:46 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/9b9c0831/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; }
