[
https://issues.apache.org/jira/browse/FLINK-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711510#comment-14711510
]
ASF GitHub Bot commented on FLINK-2291:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1016#issuecomment-134646755
Looks very good. Minor comments that we may address after this pull request:
- The Flink Mini cluster becomes tricky, the configurations ever more
intransparent. This could use a rework.
- You shade curator in Hadoop, but not in Flink. Do we expect collisions
with other systems that use Curator, like newer versions of the Kafka
consumers? (IIRC 0.8.3 starts using Curator).
> Use ZooKeeper to elect JobManager leader and send information to TaskManagers
> -----------------------------------------------------------------------------
>
> Key: FLINK-2291
> URL: https://issues.apache.org/jira/browse/FLINK-2291
> Project: Flink
> Issue Type: Sub-task
> Components: JobManager, TaskManager
> Affects Versions: 0.10
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
> Fix For: 0.10
>
>
> Use ZooKeeper to determine the leader of a set of {{JobManagers}} which will
> act as the responsible {{JobManager}} for all {{TaskManager}}. The
> {{TaskManager}} will get the address of the leader from ZooKeeper.
> Related Wiki:
> [https://cwiki.apache.org/confluence/display/FLINK/JobManager+High+Availability]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
