[
https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MalcolmSanders updated FLINK-11808:
-----------------------------------
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|https://github.com/etcd-io/jetcd/issues/473]
was:
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.
> Implement etcd based SharedCount or sequencer
> ---------------------------------------------
>
> Key: FLINK-11808
> URL: https://issues.apache.org/jira/browse/FLINK-11808
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: MalcolmSanders
> Assignee: MalcolmSanders
> Priority: Minor
>
> 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|https://github.com/etcd-io/jetcd/issues/473]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
