[
https://issues.apache.org/jira/browse/FLINK-37529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-37529:
----------------------------------
Description:
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}
> 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)
