Hi Xintong: Thanks for your pointers. I tried -Dparallelism.default=2 locally (in IDE) and it did not work. Do you know if there is a common way that would work both for emr, locally and ide ? Thanks again. On Thursday, June 27, 2019, 12:03:06 AM EDT, Xintong Song <tonysong...@gmail.com> wrote: Hi Singh, You can use the environment variable "FLINK_CONF_DIR" to specify path to the directory of config files. You can also override config options with command line arguments prefixed -D (for yarn-session.sh) or -yD (for 'flink run' command).
Thank you~ Xintong Song On Wed, Jun 26, 2019 at 9:13 PM M Singh <mans2si...@yahoo.com> wrote: Hi: I have a single EMR cluster with Flink and want to run multiple applications on it with different flink configurations. Is there a way to 1. Pass the config file name for each application, or2. Overwrite the config parameters via command line arguments for the application. This is similar to how we can overwrite the default parameters in spark I searched the documents and have tried using ParameterTool with the config parameter names, but it has not worked as yet. Thanks for your help. Mans