paimon
paimon copied to clipboard
[flink][flink-cdc] Add FLOAT type adaptation to HAVE_SCALE_LIST
Purpose
Fixed the problem that when using cdc for data synchronization, when the field type of the data source is float, an exception message will appear during synchronization: just like … :java.lang.NumberFormatException: For input string: "10,2"
Tests
API and Format
Documentation
@JingsongLi please review, thanks!