You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ruan Hang (Jira)" <ji...@apache.org> on 2025/04/02 03:10:00 UTC
[jira] [Resolved] (FLINK-37529) Add flink-cdc-commom to the package to all the incremental source framework
[ https://issues.apache.org/jira/browse/FLINK-37529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ruan Hang resolved FLINK-37529.
-------------------------------
Resolution: Fixed
master(3.4-SNAPSHOT): d6f8bd4355e995a3f6f986b8f7fd51b8f6a6712b
> Add flink-cdc-commom to the package to all the incremental source framework
> ---------------------------------------------------------------------------
>
> Key: FLINK-37529
> URL: https://issues.apache.org/jira/browse/FLINK-37529
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Affects Versions: cdc-3.3.0
> Reporter: Hongshun Wang
> Assignee: Hongshun Wang
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.4.0
>
>
> Currently, flink-cdc-base dependends on flink-cdc-common. Thus, all its children module( such as flink-connector-postgres-cdc, flink-connector-mongo-cdc).
>
> However, {*}flink-cdc-base is not a uber jar{*}. Thus, If children module(such as flink-sql-connector-postgres-cdc and flink-sql-connector-mongo-cdc) doesn't include flink-cdc-common when shading, it will lack it.
>
> IncrementalSourceSplitReader will thrown exception when invoking org.apache.flink.cdc.common.utils.Preconditions#checkState(boolean).
> {code:java}
> private ChangeEventRecords pollSplitRecords() throws InterruptedException {
> checkState(reusedScanFetcher != null);
> } {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)