Flink SQL填坑记2：Flink和MySQL的Bigdata类型不同导致ClassCastException报错

IT源哥

于 2023-12-18 19:57:22 发布

阅读量1.2k

点赞数 6

分类专栏：源哥讲互联网技术大数据、微服务、SaaS、CRM、在线客服、呼叫中心技术文章标签：大数据 flink flink sql

本文链接：https://blog.csdn.net/sunlen/article/details/135070387

版权

源哥讲互联网技术同时被 2 个专栏收录

58 篇文章 ¥19.90 ¥99.00

订阅专栏

超级会员免费看

大数据、微服务、SaaS、CRM、在线客服、呼叫中心技术

37 篇文章 ¥9.90 ¥99.00

订阅专栏

超级会员免费看

在使用Flink SQL关联Kafka和MySQL表时，遇到由于MySQL表中bigint(20) unsigned字段超出Long类型范围，引发BigInteger到Long转换异常。解决方案是将Flink SQL中的表定义字段类型改为decimal(20,2)，避免类型转换问题。" 124214957,12793558,配置Anaconda虚拟环境与CUDA编译器,"['Python', 'conda', 'CUDA', 'PyTorch', '开发环境']

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

最近在开发Flink SQL的时候，需要关联Kafka事实表和MySQL维表，得到的数据写入Phoenix表中，但是其中有个字段，Kafka表、MySQL表和Phoenix表都是BigData类型，但是在实现的时候却报“java.math.BigInteger cannot be cast to java.lang.Long”异常，从报错信息来看，是由于BigInteger 和Long的转换出现问题，下面详细讲解一下报错过程。

具体报错信息如下：

java.lang.RuntimeException: java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long
    at org.apache.flink.table.runtime.operators.join.lookup.LookupJoinWithCalcRunner$CalcCollector.collect(LookupJoinWithCalcRunner.java:82)
    at org.apache.flink.table.runtime.operators.join.lookup.LookupJoinWith