1. 问题说明
使用Flink CDC 读取mysql数据时,当表字段为decimal时,读取的数据变成了字符串。
如下示例:
环境:
Flink 1.18.0
Flink CDC 3.1.1
mysql 8
mysql的数据如下:
使用Flink CDC读取后的数据如下:
为了方便看,复制出来就是:
{“id”:1,“price”:“AZA=”,“amount”:“wjk”}
{“id”:3,“price”:“BXg=”}
{“id”:2,“price”:“CJg=”}
使用的官方的例子:
import org.apache.flink.api.common.eventtime.WatermarkStrategy;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironme