[jira] [Created] (FLINK-9830) submit job to yarn-flink cluster base on java API
Li Lei created FLINK-9830:
Summary: submit job to yarn-flink cluster base on java API
Issue Type: Bug
Affects Versions: 1.5.0
Environment: CentOS 6.7
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