[
https://issues.apache.org/jira/browse/FLINK-34766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828691#comment-17828691
]
Flink CDC Issue Import commented on FLINK-34766:
------------------------------------------------
Date: Tue Jan 10 20:46:39 CST 2023, Author:
[gunnarmorling|https://github.com/gunnarmorling]
Hey @leonardBang, happy to send a PR for this if you agree this makes sense.
After discussing with @rmetzger, we think it should be doable rather easily by
checking `StreamingRuntimeContext::isCheckpointingEnabled()` in
`DebeziumSourceFunction::open()`. WDYT?
> 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)
