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)