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

Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Minor
    • Resolution: Duplicate
    • None
    • 1.1.0
    • None
    • None

    Description

      The FlinkYarnSessionCli class tries to calculate how many slots each taskmanager gets based on the user-supplied parallelism option. It's using an int, so when -p < -yn it is truncated to 0 and the cluster then fails to start, saying slots per TM must be positive. And example command to trigger this would be:

      bin/flink run -m yarn-cluster -d -yn 20 -ys 2 -p 5 <a jar>

      Attachments

        Issue Links

          duplicates

          Bug - A problem which impairs or prevents the functions of the product. FLINK-4139 Yarn: Adjust parallelism and task slots correctly

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Activity

            People

              Unassigned Unassigned
              chogue Chris Hogue
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: