[jira] [Created] (CASSANALYTICS-205) Handle varint/decimal values outside the Avro fixed(16)/decimal(38) range in CDC Avro conversion

["Yifan Cai (Jira)" <ji...@apache.org>]

Yifan Cai created CASSANALYTICS-205:
---------------------------------------

             Summary: Handle varint/decimal values outside the Avro fixed(16)/decimal(38) range in CDC Avro conversion
                 Key: CASSANALYTICS-205
                 URL: https://issues.apache.org/jira/browse/CASSANALYTICS-205
             Project: Apache Cassandra Analytics
          Issue Type: Bug
          Components: CDC
            Reporter: Yifan Cai


CqlToAvroSchemaConverterImplementation maps CQL decimal and varint to Avro fixed(16) with decimal(38,19) and decimal(38,0), but both Cassandra types are unbounded. A value of 2^127 or larger, more than 38 digits, or a decimal scale above 19 makes the Avro serialization throw, and because the CDC micro-batch retries from the same position, the stream stops advancing. This change represents these types losslessly, or routes values that cannot be represented to a skip/dead-letter path with a log message and metric.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org