RocMarshal created FLINK-17472:
----------------------------------
Summary: 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
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)
