I'm trying to migrate a job from Flink 1.3.1 to 1.5.1 but it seems that RequiredParameters and ParameterTool works differently from before...
My code is the following:
ParameterTool parameters = ParameterTool.fromArgs(args);
RequiredParameters required = new RequiredParameters();
required.add(getMyBooleanOption());
required.applyTo(parameters);
where getMyBooleanOption() creates an Option 'xxx' with a default value of "true".
In Flink 1.3.1 parameters.getBoolean(getMyBooleanOption().getName()) returns true while in 1.5.1 throws an exception:
Exception in thread "main" java.lang.RuntimeException: No data for required key 'xxx'
at org.apache.flink.api.java.utils.ParameterTool.getRequired(ParameterTool.java:289)
at org.apache.flink.api.java.utils.ParameterTool.getBoolean(ParameterTool.java:427)
Is this a regression or is the inteded behaviour? This could be simply fixed using
parameters.getBoolean(getMyBooleanOption().getName(),Boolean.valueOf(getMyBooleanOption().getDefaultValue()));
but the previous mechanism was better (IMHO).
Thanks in advance,
Flavio
Locked
