Skip to content

[cdc-composer] use DataSinkWriterOperatorFactory to replace all SinkWriterOperatorFactory.#2773

Merged
PatrickRen merged 1 commit intoapache:masterfrom
lvyanquan0624:fix
Nov 29, 2023
Merged

[cdc-composer] use DataSinkWriterOperatorFactory to replace all SinkWriterOperatorFactory.#2773
PatrickRen merged 1 commit intoapache:masterfrom
lvyanquan0624:fix

Conversation

@lvyanquan
Copy link
Copy Markdown
Contributor

A fix to support TwoPhaseCommittingSink for DataSink.

@lvyanquan
Copy link
Copy Markdown
Contributor Author

@leonardBang @PatrickRen PTAL.

Copy link
Copy Markdown
Contributor

@PatrickRen PatrickRen left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@lvyanquan Thanks for the patch! LGTM.

@PatrickRen PatrickRen merged commit 99ffbe0 into apache:master Nov 29, 2023
e-mhui pushed a commit to e-mhui/flink-cdc-connectors that referenced this pull request Dec 2, 2023
ChaomingZhangCN pushed a commit to ChaomingZhangCN/flink-cdc that referenced this pull request Jan 13, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants