0
点赞
收藏
分享

微信扫一扫

ChatGPT 3.5/4.0新手使用手册

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
举报

相关推荐

0 条评论