HI Kostas/Yang/Lake:
I am looking at aws emr and did not see the execution.target in the
flink-conf.yaml file under flink/conf directory. Is it defined in another place
?
I also did search in the current flink source code and did find mention of it
in the md files but not in any property file or the flink-yarn sub module.
Please let me know if I am missing anything.
Thanks
On Wednesday, May 27, 2020, 03:51:28 AM EDT, Kostas Kloudas
<kklou...@gmail.com> wrote:
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
