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
