Flink CDC读取Mysql时，Decimal类型数据异常，变成了字符串（源码解析及解决方案）

本文主要是介绍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类型数据异常，变成了字符串（源码解析及解决方案）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---