[
https://issues.apache.org/jira/browse/FLINK-32514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808171#comment-17808171
]
Dong Lin commented on FLINK-32514:
----------------------------------
[~martijnvisser] Sorry for the issue. It appears that we should added a default
implementation (i.e. an empty body) for the newly-added method
SplitEnumeratorContext#setIsProcessingBacklog for this PR to be backward
compatible.
I think we need to add the default implementation in the next Flink 1.19 minor
release. And we would need to update the Flink Kafka connector source code to
add an empty implementation for this method to unblock its release.
[~yunfengzhou] Do you have time to create PR for these changes? I can help
review the PR.
> FLIP-309: Support using larger checkpointing interval when source is
> processing backlog
> ---------------------------------------------------------------------------------------
>
> Key: FLINK-32514
> URL: https://issues.apache.org/jira/browse/FLINK-32514
> Project: Flink
> Issue Type: New Feature
> Components: Runtime / Checkpointing
> Reporter: Yunfeng Zhou
> Assignee: Yunfeng Zhou
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.19.0
>
>
> Umbrella issue for
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-309%3A+Support+using+larger+checkpointing+interval+when+source+is+processing+backlog
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
