Hi Singh, The only thing to add to what Yang said is that the "execution.target" configuration option (in the config file) is also used for the same purpose from the execution environments.
Cheers, Kostas On Wed, May 27, 2020 at 4:49 AM Yang Wang <danrtsey...@gmail.com> wrote: > > Hi M Singh, > > The Flink CLI picks up the correct ClusterClientFactory via java SPI. You > could check YarnClusterClientFactory#isCompatibleWith for how it is activated. > The cli option / configuration is "-e/--executor" or execution.target (e.g. > yarn-per-job). > > > Best, > Yang > > M Singh <mans2si...@yahoo.com> 于2020年5月26日周二 下午6:45写道： >> >> Hi: >> >> I wanted to find out which parameter/configuration allows flink cli pick up >> the appropriate cluster client factory (especially in the yarn mode). >> >> Thanks
