ruanhang1993 commented on PR #3767: URL: https://github.com/apache/flink-cdc/pull/3767#issuecomment-2791672888
@JNSimba In the backfill task, there may be one problem for projection. See `RecordUtils.upsertBinlog` in `SnapshotSplitReader#pollSplitRecords`. For tables with PK, we use all PK columns to deduplicate the records. For tables with no PK, we use all columns to deduplicate the records. So the limit for the projection is as follows. For tables with PK, we need to keep all PK columns. For tables with no PK, we need to keep all columns. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
