incubator-flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arv...@apache.org
Subject svn commit: r1304637 - /incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java
Date Fri, 23 Mar 2012 22:36:30 GMT
Author: arvind
Date: Fri Mar 23 22:36:29 2012
New Revision: 1304637

URL: http://svn.apache.org/viewvc?rev=1304637&view=rev
Log:
FLUME-1036. Reconfiguration of AVRO or NETCAT source causes port bind exception.

(Hari Shreedharan via Arvind Prabhakar)

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=1304637&r1=1304636&r2=1304637&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
Fri Mar 23 22:36:29 2012
@@ -56,12 +56,12 @@ public class DefaultLogicalNodeManager e
     if (this.nodeConfiguration != null) {
       logger
           .info("Shutting down old configuration: {}", this.nodeConfiguration);
-      for (Entry<String, SinkRunner> entry : nodeConfiguration.getSinkRunners()
+      for (Entry<String, SinkRunner> entry : this.nodeConfiguration.getSinkRunners()
           .entrySet()) {
         nodeSupervisor.unsupervise(entry.getValue());
       }
 
-      for (Entry<String, SourceRunner> entry : nodeConfiguration
+      for (Entry<String, SourceRunner> entry : this.nodeConfiguration
           .getSourceRunners().entrySet()) {
         nodeSupervisor.unsupervise(entry.getValue());
       }



Mime
View raw message