[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747737#comment-17747737
]
Fang Yong commented on FLINK-32698:
-----------------------------------
[~Ming Li] `ManagedSnapshotContext` is a `public` interface and there should be
a flip if you want to add something in it.
On the other hand, I found the sink operator in `Paimon` is a
`OneInputStreamOperator` which is also `public` in flink and it has
`snapshotState` method which has `snapshotType` in `CheckpointOptions`, maybe
we can consider it first.
> Add getCheckpointOptions interface in ManagedSnapshotContext
> ------------------------------------------------------------
>
> Key: FLINK-32698
> URL: https://issues.apache.org/jira/browse/FLINK-32698
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Checkpointing
> Reporter: Ming Li
> Priority: Major
>
> Currently only {{checkpointID}} and {{checkpointTimestamp}} information are
> provided in {{{}ManagedSnapshotContext{}}}. We hope to provide more
> information about {{{}CheckpointOptions{}}}, so that operators can adopt
> different logics when performing {{{}SnapshotState{}}}.
>
> An example is to adopt different behaviors according to the type of
> checkpoint. For example, in {{{}Paimon{}}}, we hope that the paimon‘s
> snapshot written by {{checkpoint}} can expire automatically, while the
> paimon‘s snapshot written by {{savepoint}} can be persisted.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
