joeyutong commented on issue #1034: URL: https://github.com/apache/flink-agents/issues/1034#issuecomment-5422829509
Regarding the proposed `checkpointId -> effective marker` mapping: today, each subtask stores its own marker in union state, while the per-partition minimum is only derived during restore; there is no authoritative global mapping. For v1, I suggest using the selected completed checkpoint itself as the source of truth. The cleanup tool could accept a reference to that checkpoint, read its union markers, compute the per-partition minimum, and capture the result in an immutable cleanup plan. This avoids introducing a runtime registry that depends on best-effort checkpoint-completion notifications. If the current checkpoint state cannot be inspected reliably, making the marker typed and inspectable seems like the narrow prerequisite. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
