in analytics/src/main/java/com/amazonaws/services/kinesisanalytics/utils/ParameterToolUtils.java [23:37]
public static ParameterTool fromArgsAndApplicationProperties(String[] args) throws IOException {
//read parameters from command line arguments (for debugging)
ParameterTool parameter = ParameterTool.fromArgs(args);
//read the parameters from the Kinesis Analytics environment
Map<String, Properties> applicationProperties = KinesisAnalyticsRuntime.getApplicationProperties();
Properties flinkProperties = applicationProperties.get("FlinkApplicationProperties");
if (flinkProperties != null) {
parameter = parameter.mergeWith(ParameterToolUtils.fromApplicationProperties(flinkProperties));
}
return parameter;
}