[
https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35323:
-------------------------------
Fix Version/s: cdc-3.1.1
cdc-3.2.0
> Only the schema of the first hit table is recorded when the source-table of
> the transformer hits multiple tables
> ----------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-35323
> URL: https://issues.apache.org/jira/browse/FLINK-35323
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.1.0
> Reporter: Wenkai Qi
> Assignee: yux
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.2.0, cdc-3.1.1
>
> Original Estimate: 168h
> Remaining Estimate: 168h
>
> {code:java}
> transform:
> - source-table: mydb.web_\.*
> projection: \*, localtimestamp as new_timestamp
> description: project fields from source table {code}
> Table mydb.web_order: col1, col2, col3
> Table mydb.web_info: col1, col4
> If transform data operator processes `mydb.web_info` first and then
> `mydb.web_order`, its schema will always be `col1, col4`.
> Cause by: TransformDataOperator.java
> {code:java}
> private transient Map<TransformProjection, TransformProjectionProcessor>
> transformProjectionProcessorMap;
> private transient Map<TransformFilter, TransformFilterProcessor>
> transformFilterProcessorMap; {code}
> The relationship of `TableId` is missing here.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
