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 <[email protected]> Authored: Thu Oct 24 22:18:37 2013 -0700 Committer: Hari Shreedharan <[email protected]> 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; }
