The GitHub Actions job "Flink CDC CI" on flink-cdc.git/master has failed.
Run started by GitHub user lvyanquan (triggered by lvyanquan).

Head commit for run:
be7d37489f217b218e5cb2fb74ae2e07bb786197 / haruki <[email protected]>
[FLINK-39757] Fix kafka sink could not serialize debezium json with column 
default values (#4416)

When a column has a non-string default value expression, Debezium JSON 
serialization fails.
This fix adds a convertDefaultValue method that converts the string default 
value expression to the correct Java type matching the Debezium schema, 
supporting BOOLEAN, TINYINT, SMALLINT, INTEGER, BIGINT, FLOAT, DOUBLE, DECIMAL, 
DATE, TIME, TIMESTAMP, BINARY, VARBINARY, and other types. Corresponding test 
cases are also added.

Co-authored-by: 春栖 <[email protected]>

Report URL: https://github.com/apache/flink-cdc/actions/runs/26708168115

With regards,
GitHub Actions via GitBox

Reply via email to