Local Flink configuration working autonomously from the IDE

Question

If I want to run the Flink application locally, directly from Intellij, but I need to specify configuration parameters (for example, fs.hdfs.hdfssite to configure S3 access), is there any other way to provide these configuration parameters besides ExecutionEnvironment.createLocalEnvironment(conf)? What if I want to use StreamExecutionEnvironment.getExecutionEnvironment? Can I configure Flink in my project and point to it with a local application?

Is this the right way to do this? Or did you set up your IDE to send the application to a real local Flink instance?

Answer 1

To create StreamExecutionEnvironmentwith configuration options, use this callStreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)

Answer 2

StreamExecutionEnvironment.getExecutionEnvironment() - , IDE "LocalEnvironemnt".

, conf/flink-conf.yaml .