当前位置: 首页 > article >正文

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

http://www.kler.cn/a/286473.html

相关文章:

  • Java 分布式与微服务架构:现代企业应用开发的新范式
  • docker中运行的MySQL怎么修改密码
  • floodfill算法(6题)
  • 数据结构 队列
  • 全面解析文件上传下载删除漏洞:风险与应对
  • iperf 测 TCP 和 UDP 网络吞吐量
  • 【Linux 从基础到进阶】Apache服务器搭建与优化
  • IDEA2023的激活与安装
  • Leetcode 257-二叉树的所有路径
  • 【Vue】router和route的区别
  • 不同材质的O型圈优缺点及其应用范围
  • 计算机网络端口
  • 《机器学习》 DBSCAN算法 原理、参数解析、案例实现
  • Flink窗口API使用教程
  • 2024年6月 青少年等级考试机器人实操真题二级
  • Web3常见概念
  • 系统分析师6:计算机网络
  • HTML学习笔记——用HTML记录学习过程5-全局属性
  • 如何用Java SpringBoot+Vue打造高效产品订单管理系统?
  • Markdown语法与Latex公式汇总
  • Linux网络:TCP UDP socket
  • Vue3: customRef自定义响应数据
  • Springboot + AOP + 注解做全局日志拦截并且排除敏感属性以及接口相应时间
  • Web:PHP序列化和反序列化
  • TLS握手性能测试工具:快速重置、多线程与高级统计分析(C/C++代码实现)
  • 一.海量数据实时分析-Doris入门和安装