[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889947#comment-17889947
]
LvYanquan commented on FLINK-36546:
-----------------------------------
Hi Morozov, thanks for this optimization.
I suggest setting the target version to cdc-3.3.0 As we plan to expand the data
synchronization pipeline to support batch synchronization scenarios[1].
[[1]https://lists.apache.org/thread/ypqzb5ynx7cmwfko1blb3ol1sm1jz5q6|https://lists.apache.org/thread/ypqzb5ynx7cmwfko1blb3ol1sm1jz5q6]
> 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
> Priority: Minor
> Labels: pull-request-available
>
> Currently, there is hard-coded {{boolean isBatchMode = false}} in
> {{DataSinkTranslator}}.
> Assume that there is a sink that has some logic executed at the end of the
> batch. This is is determined by the {{endOfInput}} parameter passed to
> {{SinkWriter#flush}}.
> Testing such a sink with the "values" connector as the source is challenging
> since the sink never receives the end-of-input signal.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
