ironman-star opened a new pull request, #4424: URL: https://github.com/apache/flink-cdc/pull/4424
Jira: https://issues.apache.org/jira/browse/FLINK-39832 OracleTypeUtils.fromDbzColumn mapped NUMBER(p,0) to BIGINT for all precisions, but Debezium encodes p>=19 as DECIMAL(BYTES). The mismatch caused the sink to read a BinaryRecordData pointer as a long, producing a constant garbage PK (171798691841) and collapsing all rows on upsert. Fix: return DECIMAL(p,0) when p>=19, aligned with Debezium runtime behavior. Tested with Oracle XE 11.2, NUMBER(19,0) PK, including 19-digit large IDs (9000000000000000001). Snapshot and incremental (INSERT/UPDATE/DELETE) all verified correct. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
