[jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer

Shang Yuanchun (Jira)
MalcolmSanders created FLINK-11808:
--------------------------------------

             Summary: etcd based SharedCount or sequencer
                 Key: FLINK-11808
                 URL: https://issues.apache.org/jira/browse/FLINK-11808
             Project: Flink
          Issue Type: Sub-task
            Reporter: MalcolmSanders
            Assignee: MalcolmSanders


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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)