Local Flink config running standalone from IDE

To create a StreamExecutionEnvironment with configuration options, use this call StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)


I could load the flink-conf.yaml file by providing the ENV_VAR FLINK_CONF_DIR in IntelliJ Run Configuration


You can use StreamExecutionEnvironment.getExecutionEnvironment() -- it will figure out the current setting and if executed in an IDE will return an "LocalEnvironemnt".

Thus, should be able to use conf/flink-conf.yaml to set your configuration values.

Tags:

Apache Flink