While debugging in IntelliJ I’d like to override some of the LocalEnvironment settings. E.g parallelism from a config or via parameters and not in code. Despite setting FLINK_CONF_DIR and providing parallelism.default: 1 in the fink-conf.yaml the default value of parallelism as the number of cores gets used. How can I achieve the above?

You can try the following code:

Configuration configuration = new Configuration();
configuration.set(CoreOptions.DEFAULT_PARALLELISM, 1);
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(configuration);

If it’s possible, I’d like to achieve this within the Flink-conf.yaml file or by passing arguments. Not by changing the job’s code.