[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747789#comment-17747789
]
Ming Li commented on FLINK-32698:
---------------------------------
[~zjureel] [~zhuzh] [~fanrui] Thanks for your suggestions, I will try to
extend {{OneInputStreamOperator}} to verify whether it meets the needs. I'm
going to create a community discussion email later, detailing the background
and needs. Looking forward to your reply.
> 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)
