Wenkai Qi created FLINK-35323:
---------------------------------
Summary: 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: 3.1.0
Reporter: Wenkai Qi
{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)
