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)