You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by ar...@apache.org on 2012/03/23 23:36:30 UTC
svn commit: r1304637 -
/incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/node/nodemanager/DefaultLogicalNodeManager.java
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());
}