You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC

[jira] [Created] (FLINK-34766) Ensure checkpointing is enabled for Postgres connector

Flink CDC Issue Import created FLINK-34766:
----------------------------------------------

             Summary: 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


**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)