[
https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-17472:
-------------------------------------
Docs Text: (was: There may be many details about this new feature that we
have to pay attention to. As discussed in jira below.
https://issues.apache.org/jira/browse/FLINK-14964;
https://issues.apache.org/jira/browse/FLINK-13938;
https://issues.apache.org/jira/browse/FLINK-17412)
> StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode
> ----------------------------------------------------------------
>
> Key: FLINK-17472
> URL: https://issues.apache.org/jira/browse/FLINK-17472
> Project: Flink
> Issue Type: New Feature
> Components: Client / Job Submission, Deployment / YARN
> Affects Versions: 1.10.0
> Reporter: RocMarshal
> Priority: Major
> Attachments: demo.png
>
>
> Expect to have such a mode of submission. Build the task directly in the
> Environment, and then submit the task in yarn mode. Just like
> RemoteStreamEnvironment, as long as you specify the parameters of the yarn
> cluster (host, port) or yarn configuration directory and HADOOP_USER_NAME,
> you can use the topology built by Env to submit the task .
> This submission method is best to minimize the transmission of resources
> required by yarn to start flink-jobmanager and taskmanagerrunner to ensure
> that flink can deploy tasks on the yarn cluster as quickly as possible.
> The simple demo as shown in the attachment .the parameter named 'env'
> containes all the operators about job ,like sources,maps,etc..
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
