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 >
