[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851498#comment-17851498 ]
Leonard Xu edited comment on FLINK-35323 at 6/3/24 4:06 AM: ------------------------------------------------------------ master: 88afc5f18d051b52da86b5017dc896a4a66e6e10 3.1: f4045fb8e78d905c0c7494a0485b1aca40a12f62 was (Author: leonard xu): master: 88afc5f18d051b52da86b5017dc896a4a66e6e10 > 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)