paimon
paimon copied to clipboard
[flink][flink-cdc] Improve the compatibility of getting kafka-cdc precision and scale
Purpose Fixed the problem that when using kafka-cdc for data synchronization, when the field type of the data source is float(10,2) or double(8), an exception message will appear when getPrecision and getScale: just like … :java.lang.NumberFormatException: For input string: "10,2", or java.lang.NumberFormatException: For input string: "DOUBLE(8" ...
Tests API and Format Documentation
@JingsongLi please review,thanks