[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-36546:
-------------------------------
Fix Version/s: (was: cdc-3.5.0)
> Handle batch sources in DataSinkTranslator
> ------------------------------------------
>
> Key: FLINK-36546
> URL: https://issues.apache.org/jira/browse/FLINK-36546
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Affects Versions: cdc-3.2.0
> Reporter: Sergei Morozov
> Assignee: Sergei Morozov
> Priority: Minor
> Labels: pull-request-available
>
> Currently, there is hard-coded {{boolean isBatchMode = false}} in
> {{DataSinkTranslator}}.
> Assume the following pipeline:
> 1. The source is a bounded source.
> 2. The sink is a two-phase committing sink.
> In this setup, when {{CommitterOperator#endInput()}} is invoked, it will not
> call {{notifyCheckpointComplete(Long.MAX_VALUE)}}. As a result, when
> {{CommitterOperator#processElement()}} is invoked with the last committable
> (whose checkpoint id set to {{Long.MAX_VALUE}}), this element will be ignored
> because it will be greater than {{lastCompletedCheckpointId}}.
> As a result, the events at the end of the input may remain uncommitted.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
