Li Lei created FLINK-9830:
-----------------------------
Summary: submit job to yarn-flink cluster base on java API
Key: FLINK-9830
URL: https://issues.apache.org/jira/browse/FLINK-9830
Project: Flink
Issue Type: Bug
Components: YARN
Affects Versions: 1.5.0
Environment: CentOS 6.7
JAVA 1.8.0_151
Flink 1.5.0
Hadoop 2.6.5
Reporter: Li Lei
I use JAVA API to submit jobs to the Yarn cluster, the
StreamExecutionEnvironment execute submit the job through RestClusterClient.
and the webmonitor URL is the jobmanager.rpc.address configed in configuration
flink-conf.yaml file.
But the flink-session that running on the yarn cluster does not use the
configuration which is in flink-conf.yaml ...
I want to know the correct method that submit Flink Job to Yarn cluster through
Java API.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
