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

Typo in JobGraph generator Exception

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Trivial
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.2.0, 1.3.0
    • Component/s: Client
    • Labels:
      None

      Description

      When trying to run a job with parallelism > max parallelism there is a typo in the error message:

      Caused by: java.lang.IllegalStateException: The maximum parallelism (1) of the stream node Flat Map-3 is smaller than the parallelism (18). Increase the maximum parallelism or decrease the parallelism >>>ofthis<<< operator.
      at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobVertex(StreamingJobGraphGenerator.java:318)
      

        Issue Links

          Activity

          Hide
          StephanEwen Stephan Ewen added a comment -

          Fixed in

          • 1.2.0 via 30b467f266970e267792411d3148b4379ec23439
          • 1.3.0 via c2f28c013116328583043ca1433c45c85e32de30
          Show
          StephanEwen Stephan Ewen added a comment - Fixed in 1.2.0 via 30b467f266970e267792411d3148b4379ec23439 1.3.0 via c2f28c013116328583043ca1433c45c85e32de30
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/flink/pull/3098

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3098
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user StephanEwen commented on the issue:

          https://github.com/apache/flink/pull/3098

          Agree, merging this...

          Show
          githubbot ASF GitHub Bot added a comment - Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3098 Agree, merging this...
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user KurtYoung commented on the issue:

          https://github.com/apache/flink/pull/3098

          Hi @mtunique , thanks for your effort.
          Can't see any reason we shouldn't merge this.

          Show
          githubbot ASF GitHub Bot added a comment - Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3098 Hi @mtunique , thanks for your effort. Can't see any reason we shouldn't merge this.
          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user mtunique opened a pull request:

          https://github.com/apache/flink/pull/3098

          FLINK-5438 Typo in JobGraph generator Exception

          Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.
          If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the [How To Contribute guide](http://flink.apache.org/how-to-contribute.html).
          In addition to going through the list, please provide a meaningful description of your changes.

          • [x] General
          • The pull request references the related JIRA issue ("[FLINK-XXX] Jira title text")
          • The pull request addresses only one issue
          • Each commit in the PR has a meaningful commit message (including the JIRA id)
          • [ ] Documentation
          • Documentation has been added for new functionality
          • Old documentation affected by the pull request has been updated
          • JavaDoc for public methods has been added
          • [ ] Tests & Build
          • Functionality added by the pull request is covered by tests
          • `mvn clean verify` has been executed successfully locally or a Travis build has passed

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/mtunique/flink flink-5438

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/flink/pull/3098.patch

          To close this pull request, make a commit to your master/trunk branch
          with (at least) the following in the commit message:

          This closes #3098


          commit 4e141e4573e8fb533d59f0080b6174fafb542a1d
          Author: mtunique <oatgnem@gmail.com>
          Date: 2017-01-12T04:02:49Z

          FLINK-5438 Typo in JobGraph generator Exception


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user mtunique opened a pull request: https://github.com/apache/flink/pull/3098 FLINK-5438 Typo in JobGraph generator Exception Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items into account, feel free to open your pull request. For more information and/or questions please refer to the [How To Contribute guide] ( http://flink.apache.org/how-to-contribute.html ). In addition to going through the list, please provide a meaningful description of your changes. [x] General The pull request references the related JIRA issue (" [FLINK-XXX] Jira title text") The pull request addresses only one issue Each commit in the PR has a meaningful commit message (including the JIRA id) [ ] Documentation Documentation has been added for new functionality Old documentation affected by the pull request has been updated JavaDoc for public methods has been added [ ] Tests & Build Functionality added by the pull request is covered by tests `mvn clean verify` has been executed successfully locally or a Travis build has passed You can merge this pull request into a Git repository by running: $ git pull https://github.com/mtunique/flink flink-5438 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3098.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3098 commit 4e141e4573e8fb533d59f0080b6174fafb542a1d Author: mtunique <oatgnem@gmail.com> Date: 2017-01-12T04:02:49Z FLINK-5438 Typo in JobGraph generator Exception

            People

            • Assignee:
              Unassigned
              Reporter:
              uce Ufuk Celebi
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development