Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21153

yarn-per-job deployment target ignores yarn options

    XMLWordPrintableJSON

Details

    Description

      While looking into the problem reported in FLINK-6949, I stumbled across an odd behaviour of Flink. I tried to deploy a Flink cluster on Yarn and ship some files to the cluster. Only the first command successfully shipped the additional files to the cluster:

      1) bin/flink run -p 1 --yarnship ../flink-test-job/cluster -m yarn-cluster ../flink-test-job/target/flink-test-job-1.0-SNAPSHOT.jar
      2) bin/flink run -p 1 --yarnship ../flink-test-job/cluster -t yarn-per-job ../flink-test-job/target/flink-test-job-1.0-SNAPSHOT.jar

      The problem seems to be that the second command does not activate the FlinkYarnSessionCli but uses the GenericCLI.

      kkl0u, aljoscha, tison what is the intended behaviour in this case. I always thought that -m yarn-cluster and -t yarn-per-job would be equivalent.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated: