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

ApplicationClient: remove redundant proxy messages

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.2.0, 1.1.1
    • Fix Version/s: 1.2.0, 1.1.2
    • Component/s: YARN
    • Labels:
      None

      Description

      GetClusterStatus and ShutdownClusterAfterJob don't have to be proxied through the ApplicationClient's messages LocalGetyarnClusterStatus and LocalStopAMAfterJob. These messages can be directly handled by the client. The implementations are also faulty in the sense that they don't reply to the client in case the leader is not available.

        Issue Links

          Activity

          Hide
          mxm Maximilian Michels added a comment -

          master: 31c88a564a8eda263aedada0da671357d1a6f524
          release-1.1: f7ec1efb32c277a0d51479cca4450edb324a3d58

          Show
          mxm Maximilian Michels added a comment - master: 31c88a564a8eda263aedada0da671357d1a6f524 release-1.1: f7ec1efb32c277a0d51479cca4450edb324a3d58
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

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

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

          GitHub user mxm opened a pull request:

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

          FLINK-4526[yarn] remove redundant proxy messages

          Merging this with #2423 with #2419.

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

          $ git pull https://github.com/mxm/flink FLINK-4526

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

          https://github.com/apache/flink/pull/2437.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 #2437


          commit 6bd2b60670fd5c9b15f8695b8dfaa236fe39e5b4
          Author: Maximilian Michels <mxm@apache.org>
          Date: 2016-08-30T08:46:22Z

          FLINK-4526[yarn] remove redundant proxy messages


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2437 FLINK-4526 [yarn] remove redundant proxy messages Merging this with #2423 with #2419. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-4526 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2437.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 #2437 commit 6bd2b60670fd5c9b15f8695b8dfaa236fe39e5b4 Author: Maximilian Michels <mxm@apache.org> Date: 2016-08-30T08:46:22Z FLINK-4526 [yarn] remove redundant proxy messages

            People

            • Assignee:
              mxm Maximilian Michels
              Reporter:
              mxm Maximilian Michels
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development