flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Li Lei (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-9830) submit job to yarn-flink cluster base on java API
Date Thu, 12 Jul 2018 08:15:00 GMT
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

View raw message