flink-cdc
flink-cdc copied to clipboard
[FLINK-36408] Fix MySQL pipeline connector failed to parse FLOAT type with precision
Currently, MySQL SourceRecordEmitter treats FLOAT(x) (float with explicit precision) as a DOUBLE, but pipeline MetadataAccessor reports a plain "FLOAT", which causes discrepancy and corrupted deserialized data.
This bug should be fixed by adjusting MetadataAccessor logic (mapping FLOAT(x) to DOUBLE).
cc @ruanhang1993
Rebased #3696 into this, could @ruanhang1993 please trigger CI again?