Hey,

I was wondering about the relation between the parallelism set by YARN in
Yarn properties file. Currently, as far as I know there is only one
execution of `writeYarnPropertiesFIle` method and it sets the parallelism
in the YARN properties to the number of workers * number of slots per
worker. But doesn't the `flink-conf.yaml` take the precedence in resolving
the configuration ? I am trying to understand the reasoning between always
setting the Yarn properties to the max available slots and whether this
will be used at all, since there is a default value  in flink config for
paralellism.

Thanks in advance,
Best Regards,
Dom.

Reply via email to