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

Lookups for JobManager address in config

    Details

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

      Description

      At a few non-critical places for printing status messages, the code in ClusterClient checks for the JobManager address in the config. All these calls have to be replaced with a leader retrieval to make sure the correct information is printed.

        Issue Links

          Activity

          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user mxm opened a pull request:

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

          FLINK-4454 always retrieve JobManager address using LeaderRetrievalService

          CC @uce This should solve the reported problems on the mailing if an invalid JobManager address has been set in the config but HA mode is enabled.

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

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

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

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


          commit 86acb89c1557787a92c1d3fdf5e5755d87ed0fbf
          Author: Maximilian Michels <mxm@apache.org>
          Date: 2016-08-23T16:11:45Z

          FLINK-4454 always retrieve JobManager address using LeaderRetrievalService


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2406 FLINK-4454 always retrieve JobManager address using LeaderRetrievalService CC @uce This should solve the reported problems on the mailing if an invalid JobManager address has been set in the config but HA mode is enabled. You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-4454 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2406.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 #2406 commit 86acb89c1557787a92c1d3fdf5e5755d87ed0fbf Author: Maximilian Michels <mxm@apache.org> Date: 2016-08-23T16:11:45Z FLINK-4454 always retrieve JobManager address using LeaderRetrievalService
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user mxm commented on the issue:

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

          Travis gives a green light, merging...

          Show
          githubbot ASF GitHub Bot added a comment - Github user mxm commented on the issue: https://github.com/apache/flink/pull/2406 Travis gives a green light, merging...
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

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

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

          master: 720645587bc58a22db6a8d948f91384da2ecb7b7
          release-1.1: 70b818b1ba27e5e7d4758c438801681cbf5aee81

          Show
          mxm Maximilian Michels added a comment - master: 720645587bc58a22db6a8d948f91384da2ecb7b7 release-1.1: 70b818b1ba27e5e7d4758c438801681cbf5aee81

            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