Re: ClusterClientFactory selection

Posted by Yang Wang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/ClusterClientFactory-selection-tp35474p35487.html

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 <[hidden email]> 于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