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 2012/06/28 03:32:34 UTC
svn commit: r1354793 -
/incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java
Author: hshreedharan
Date: Thu Jun 28 01:32:33 2012
New Revision: 1354793
URL: http://svn.apache.org/viewvc?rev=1354793&view=rev
Log:
FLUME-1325. Components should be stopped in the correct order.
(Mike Percy via Hari Shreedharan)
Modified:
incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java
Modified: incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java?rev=1354793&r1=1354792&r2=1354793&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java (original)
+++ incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java Thu Jun 28 01:32:33 2012
@@ -54,8 +54,7 @@ public class DefaultLogicalNodeManager e
@Override
public void stopAllComponents() {
if (this.nodeConfiguration != null) {
- logger
- .info("Shutting down old configuration: {}", this.nodeConfiguration);
+ logger.info("Shutting down configuration: {}", this.nodeConfiguration);
for (Entry<String, SourceRunner> entry : this.nodeConfiguration
.getSourceRunners().entrySet()) {
try{
@@ -198,6 +197,8 @@ public class DefaultLogicalNodeManager e
logger.info("Node manager stopping");
+ stopAllComponents();
+
nodeSupervisor.stop();
logger.debug("Node manager stopped");