[
https://issues.apache.org/jira/browse/FLINK-22133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325008#comment-17325008
]
Dawid Wysakowicz commented on FLINK-22133:
------------------------------------------
Given the limited scope of the change and that there is still not much adoption
in external connectors (imo) I'd be fine with performing the final change in
1.13 already.
I think the two options do not differ much in a relation to the feature freeze.
They both include the same dangers that the checkpointId is not passed
correctly. So the real question is just if we want to break the API in a single
release or give users one extra release. Again given the limited scope I'd do
it already in 1.13.
> SplitEmumerator does not provide checkpoint id in snapshot
> ----------------------------------------------------------
>
> Key: FLINK-22133
> URL: https://issues.apache.org/jira/browse/FLINK-22133
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Common
> Affects Versions: 1.12.0
> Reporter: Brian Zhou
> Priority: Major
>
> In ExternallyInducedSource API, the checkpoint trigger exposes the checkpoint
> Id for the external client to identify the checkpoint. However, in the
> FLIP-27 source, the SplitEmumerator::snapshot() is a no-arg method. The
> connector cannot track the checkpoint ID from Flink
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
