[
https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-17472.
---------------------------------
Resolution: Won't Do
> 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: Roc Marshal
> Priority: Minor
> Labels: auto-deprioritized-major
> Attachments: demo.jpeg
>
>
> 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 external link [Simple outline of the
> Yarn-Env API（Per-Job
> Mode)|https://gitee.com/RocMarshal/resources4link/blob/master/README.md] .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)
