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