Re: ClusterClientFactory selection

Posted by Kostas Kloudas-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/ClusterClientFactory-selection-tp35474p35491.html

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