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)