本文主要是介绍Flink CDC读取Mysql时,Decimal类型数据异常,变成了字符串(源码解析及解决方案),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
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
这篇关于Flink CDC读取Mysql时,Decimal类型数据异常,变成了字符串(源码解析及解决方案)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!