[
https://issues.apache.org/jira/browse/FLINK-34766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828692#comment-17828692
]
Flink CDC Issue Import commented on FLINK-34766:
------------------------------------------------
Date: Wed Jan 11 10:32:38 CST 2023, Author:
[leonardBang|https://github.com/leonardBang]
Thanks @gunnarmorling for reporting this ticket, it makes sense to me, this
could improve all Debezium-based connectors, maybe we can make this issue to
an umbrella issue, the sub-tasks would contains :
- Ensure checkpointing is enabled for Debezium-based(DebeziumSourceFunction)
connector
- Ensure checkpointing is enabled for MySQL/JdbcIncrementalSource connector
- Ensure checkpointing is enabled for OceanBase/TiDB(xxSourceFunction) connector
> Ensure checkpointing is enabled for Postgres connector
> ------------------------------------------------------
>
> Key: FLINK-34766
> URL: https://issues.apache.org/jira/browse/FLINK-34766
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Reporter: Flink CDC Issue Import
> Priority: Major
> Labels: github-import
>
> **Is your feature request related to a problem? Please describe.**
> Yes, it is: when not enabling checkpointing with the Debezium-based Postgres
> connector, then the replication slot in the database will never be advanced
> (as this is triggered by committing offsets in Debezium, which in turn is
> triggered by checkpointing in Flink CDC), causing WAL to be retained
> indefinitely.
> **Describe the solution you'd like**
> Raise a warning or even an exception when using this connector without
> checkpointing.
> **Describe alternatives you've considered**
> n/a
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/apache/flink-cdc/issues/1866
> Created by: [gunnarmorling|https://github.com/gunnarmorling]
> Labels: enhancement,
> Assignee: [gunnarmorling|https://github.com/gunnarmorling]
> Created at: Tue Jan 10 20:43:21 CST 2023
> State: open
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
