EnvVarResolverProperties extends Properties { @Override public String getProperty(String key) { return resolveEnvVars(super.getProperty(key)); }  @Override String getProperty(String key);  }
@Test public void getProperty() throws Exception { String NC_PORT = "6667"; environmentVariables.set("NC_PORT", NC_PORT); System.setProperty("propertiesImplementation", "org.apache.flume.node.EnvVarResolverProperties"); Assert.assertEquals(NC_PORT, provider.getFlumeConfiguration() .getConfigurationFor("a1") .getSourceContext().get("r1").getParameters().get("port")); }