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/05/05 20:59:20 UTC

svn commit: r1334468 - /incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java

Author: arvind
Date: Sat May  5 18:59:20 2012
New Revision: 1334468

URL: http://svn.apache.org/viewvc?rev=1334468&view=rev
Log:
FLUME-1180. ChannelSelectorFactory creates incorrect selector for multiplexing selector type.

(Mubarak Seyed via Arvind Prabhakar)

Modified:
    incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java

Modified: incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java?rev=1334468&r1=1334467&r2=1334468&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java (original)
+++ incubator/flume/trunk/flume-ng-node/src/main/java/org/apache/flume/conf/properties/PropertiesFileConfigurationProvider.java Sat May  5 18:59:20 2012
@@ -306,7 +306,7 @@ public class PropertiesFileConfiguration
         channels.add(conf.getChannels().get(chName));
       }
 
-      Map<String, String> selectorConfig = context.getSubProperties("selector");
+      Map<String, String> selectorConfig = context.getSubProperties("selector" + ".");
 
       ChannelSelector selector = ChannelSelectorFactory.create(
           channels, selectorConfig);