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

  • 开发
  • 57

最近在开发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.LookupJoinWithCalcRunner$CalcCollector.collect(LookupJoinWithCalcRunner.java:69)
    at org.apache.flink.table.functions.TableFunction.collect(TableFunction.java:196)
    at org.apache.flink.connector.jdbc.table.Jd
阅读全部

相关推荐

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

    2023-12-19 10:42:03       58 阅读

  4. Flink SQL填坑记3：两个kafka数据关联查询

    2023-12-19 10:42:03       33 阅读

  6. SpringBoot 启动报错，EnableConfigurationProperties 注解跳坑记

    2023-12-19 10:42:03       28 阅读

  9. 记一下mysql安装过程中遇到的报错解决

    2023-12-19 10:42:03       41 阅读

最近更新

  3. docker php8.1+nginx base 镜像 dockerfile 配置

    2023-12-19 10:42:03       94 阅读

  4. Could not load dynamic library ‘cudart64_100.dll‘

    2023-12-19 10:42:03       100 阅读

  9. 在Django里面运行非项目文件

    2023-12-19 10:42:03       82 阅读

  19. Python语言-面向对象

    2023-12-19 10:42:03       91 阅读

  20. 如何分清楚常见的 Git 分支管理策略Git Flow、GitHub Flow 和 GitLab Flow

    2023-12-19 10:42:03       85 阅读

热门阅读

  1. linux中数据库的概念、mysql的两种安装方法

    2023-12-19 10:42:03       56 阅读

  2. 笔记：LVM的简单使用

    2023-12-19 10:42:03       58 阅读

  3. npm的介绍和使用

    2023-12-19 10:42:03       47 阅读

  4. openssl数据压缩

    2023-12-19 10:42:03       55 阅读

  7. Spring / Spring Boot全局获取HttpServletRequest、HttpServletResponse对象

    2023-12-19 10:42:03       61 阅读

  9. go语言实现文件夹上传前后端代码案例

    2023-12-19 10:42:03       57 阅读

  10. Python【Matplotlib】鼠标单击事件判断点击的是否为图例

    2023-12-19 10:42:03       51 阅读

  12. 获取 jira filter issue count 方法

    2023-12-19 10:42:03       66 阅读

  13. 创意产业集群与现代商业：共同探索新的商业模式

    2023-12-19 10:42:03       64 阅读

  17. pnpm-lock.yaml、yarn.lock以及package-lock.json的区别

    2023-12-19 10:42:03       55 阅读

  20. uniapp数据缓存（存储/获取/移出）

    2023-12-19 10:42:03       71 阅读

  22. ubuntu添加路由

    2023-12-19 10:42:03       58 阅读

  26. npm 安装包遇到问题的常用脚本（RequestError: socket hang up）

    2023-12-19 10:42:03       67 阅读