Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11105 Add a new implementation of the HighAvailabilityServices using etcd
  3. FLINK-11808

Implement etcd based SharedCount or sequencer

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Minor
    • Resolution: Abandoned
    • None
    • None
    • Runtime / Coordination
    • None

    Description

      Implement SharedCount or sequencer API using jetcd.

      CheckpointIDCounter is used to get and increment an integer atomically for creating checkpoint ID. Zookeeper based CheckpointIDCounter chooses SharedCount API in curator to achieve its target. While I find the implementation of SharedCount in curator somewhat complicated considering flink's use case, I think a sequencer API is adequate for the need of CheckpointIDCounter.

      jetcd issue : jetcd#473

      Attachments

        Issue Links

          is superceded by

          New Feature - A new feature of the product, which has yet to be developed. FLINK-12884 FLIP-144: Native Kubernetes HA Service

          • Major - Major loss of function.
          • Closed

          Activity

            People

              Unassigned Unassigned
              ssy MalcolmSanders
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: