Skip to content

Commit 099092b

Browse files
toddlipconGergo Repas
authored andcommitted
HADOOP-15549. Upgrade to commons-configuration 2.1 regresses task CPU consumption
Change-Id: I03d1994adc9fc0a3ca38d886c3766948d2020c74
1 parent 4484f8b commit 099092b

File tree

1 file changed

+10
-11
lines changed
  • hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/impl

1 file changed

+10
-11
lines changed

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/impl/MetricsConfig.java

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,8 @@
3737
import org.apache.commons.configuration2.Configuration;
3838
import org.apache.commons.configuration2.PropertiesConfiguration;
3939
import org.apache.commons.configuration2.SubsetConfiguration;
40-
import org.apache.commons.configuration2.builder.fluent.Configurations;
41-
import org.apache.commons.configuration2.builder.fluent.Parameters;
42-
import org.apache.commons.configuration2.convert.DefaultListDelimiterHandler;
4340
import org.apache.commons.configuration2.ex.ConfigurationException;
41+
import org.apache.commons.configuration2.io.FileHandler;
4442
import org.apache.hadoop.metrics2.MetricsFilter;
4543
import org.apache.hadoop.metrics2.MetricsPlugin;
4644
import org.apache.hadoop.metrics2.filter.GlobFilter;
@@ -112,14 +110,15 @@ static MetricsConfig create(String prefix, String... fileNames) {
112110
static MetricsConfig loadFirst(String prefix, String... fileNames) {
113111
for (String fname : fileNames) {
114112
try {
115-
Configuration cf = new Configurations().propertiesBuilder(fname)
116-
.configure(new Parameters().properties()
117-
.setFileName(fname)
118-
.setListDelimiterHandler(new DefaultListDelimiterHandler(',')))
119-
.getConfiguration()
120-
.interpolatedConfiguration();
121-
LOG.info("loaded properties from "+ fname);
122-
LOG.debug(toString(cf));
113+
PropertiesConfiguration pcf = new PropertiesConfiguration();
114+
FileHandler fh = new FileHandler(pcf);
115+
fh.setFileName(fname);
116+
fh.load();
117+
Configuration cf = pcf.interpolatedConfiguration();
118+
LOG.info("Loaded properties from {}", fname);
119+
if (LOG.isDebugEnabled()) {
120+
LOG.debug("Properties: {}", toString(cf));
121+
}
123122
MetricsConfig mc = new MetricsConfig(cf, prefix);
124123
LOG.debug(mc.toString());
125124
return mc;

0 commit comments

Comments
 (0)