flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hshreedha...@apache.org
Subject svn commit: r1354793 - /incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java
Date Thu, 28 Jun 2012 01:32:34 GMT
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");



Mime
View raw message