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

最近在开发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

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/234938.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

[CVPR-23] PointAvatar: Deformable Point-based Head Avatars from Videos

[CVPR-23] PointAvatar: Deformable Point-based Head Avatars from Videos

[paper | code | proj] 本文的形变方法被成为：Forward DeformationPointAvatar基于点云表征动态场景。目标是根据给定的一段单目相机视频，重建目标的数字人，并且数字人可驱动；通过标定空间（canonical space&#xff09…
阅读更多...
http -- 跨域问题详解（浏览器）

http -- 跨域问题详解（浏览器）

参考链接 参考链接 1. 跨域报错示例 Access to XMLHttpRequest at http://127.0.0.1:3000/ from origin http://localhost:3000 has been blocked by CORS policy: Response to preflight request doesnt pass access control check: No Access-Control-Allow-Origin header…
阅读更多...
【QT】解决QTableView修改合并单元格内容无法修改到合并范围内的单元格

【QT】解决QTableView修改合并单元格内容无法修改到合并范围内的单元格

问题：修改合并单元格的内容 修改合并单元格的内容时，希望直接修改到合并范围内的单元格，Qt没有实现这个功能，需要自己写出 Delegate来实现 方案：Delegate class EditDelegate : public QStyledItemDelegate {public:EditDelegate(QTableView *view): tableView(view){}pu…
阅读更多...
JS基础之模块化

JS基础之模块化

JS基础之模块化 JS模块化模块化前端发展 什么是模块？怎么定义模块化IIFE匿名函数自调用IIFE模式增强模块化的好处 JS模块化 模块化 JS DOM操作 代码规范管理的标准 不同模块间的管理模块内部自组织 标准bundler (模块构建工具) ESNext TS -> ES5 前端发展 生态 …
阅读更多...
Python数据处理必备：Pandas DataFrame中行迭代技巧大曝光！

Python数据处理必备：Pandas DataFrame中行迭代技巧大曝光！

更多资料获取 📚 个人网站：ipengtao.com 在数据分析和处理中，Pandas是Python中最常用的库之一，而DataFrame是Pandas的核心数据结构之一。迭代DataFrame中的行是一种常见的操作，本文将详细介绍几种迭代DataFrame行的方…
阅读更多...
android —— PopupWindow

android —— PopupWindow

一、常用方法： 1、设置显示的位置 // 一个参数 popupWindow.showAsDropDown(v); //参数1: popupWindow关联的view // 参数2和3：相对于关联控件的偏移量popupWindow.showAsDropDown(View anchor, int xoff, int yoff)2、是否会获取焦点 popupWindow.se…
阅读更多...
k8s集群内部署nexus

k8s集群内部署nexus

一、前言 在k8s集群中部署nexus服务需要使用到pv、pvc服务来存储nexus的数据，需要使用service服务来提供对外访问nexus服务的端口，需要使用deployment服务来管理nexus服务，接下来就是用这些服务来在k8s集群中搭建nexus，pv服务使用…
阅读更多...
解析js之构造函数

解析js之构造函数

一、函数介绍 函数就是将实现特定功能的代码封装起来，当我们需要实现特定功能时，直接调用函数实现即可，不需要每次都写一堆代码，实现代码的复用。 函数的作用： 1、实现功能的封装，提高代码复用率 2、用于构…
阅读更多...
【其他】数字孪生简介

【其他】数字孪生简介

数字孪生简介 一、数字孪生的概念二、数字孪生的起源三、数字孪生系统的特点四、作用和结论五、使用方式 一、数字孪生的概念 数字孪生是充分利用物理模型、传感器更新、运行历史等数据，集成多学科、多物理量、多尺度、多概率的仿真过程，在虚拟空间中完…
阅读更多...
爱芯派pro通过无线网卡rtl8188eu连接热点

爱芯派pro通过无线网卡rtl8188eu连接热点

爱芯派pro通过无线网卡rtl8188eu连接热点 爱芯派pro目前的底板的pcie的复位有问题，所以pcie接口无法挂载上去，所以自己购买的rtl8822网卡也用不了，然后想起来自己还有正点原子的rtl8188eu网卡，但是没有和工作人员进行摸索后才知道…
阅读更多...
用大白话举例子讲明白区块链

用大白话举例子讲明白区块链

什么是区块链？网上这么说： 区块链是一种分布式数据库技术，它以块的形式记录和存储交易数据，并使用密码学算法保证数据的安全性和不可篡改性。每个块都包含了前一个块的哈希值和自身的交易数据，形成了一个不断增长的链条…
阅读更多...
如何禁止外网访问公司内网服务器

如何禁止外网访问公司内网服务器

对于企业网络，经常会用到访问控制，例如限制员工的上网时间？或如何控制各部门之间的网络互通等等，在实际企业网络项目中经常会遇到，这里面我们就可以用到ACL访问列表控制了，本期我们一起来看下，如…
阅读更多...
SpringBoot已经禁掉了循环依赖！

SpringBoot已经禁掉了循环依赖！

还在问循环依赖嘛？SpringBoot已经禁掉了循环依赖！ 首发2023-12-18 11:26yuan人生 如果现在面试时还有人问你循环依赖，你就这样怼他：循环依赖是一种代码质量低下的表现，springboot2.6之后的版本已经默认禁用了。 Spr…
阅读更多...
保护电脑安全，火绒安全助手 V5.0

保护电脑安全，火绒安全助手 V5.0

火绒安全软件，也称为“火绒安全助手”是一款由中国研发的综合安全软件。火绒安全软件旨在为计算机用户提供全面的安全保护，包括防病毒、反恶意软件、网络安全、系统优化等功能。 火绒安全的功能 病毒防护：火绒提供实时的病毒和恶意软件扫描…
阅读更多...
排序算法——快排

排序算法——快排

快速排序算法最早是由图灵奖获得者Tony Hoare设计出来的,他在形式化方法理论以 及ALGOL.60编程语言的发明中都有卓越的贡献,是20世纪最伟大的计算机科学家之—。 而这快速排序算法只是他众多贡献中的—个小发明而已。 快速排序（Quick Sort）的基本算法思…
阅读更多...
C语言—每日选择题—Day57

C语言—每日选择题—Day57

指针相关博客 打响指针的第一枪：指针家族-CSDN博客 深入理解：指针变量的解引用 与 加法运算-CSDN博客 第一题 1. 下面程序段（） char *str[] {"ABC", "DEF", "GHI"}; puts(str[1]); A：A…
阅读更多...
Vue2源码梳理：在 import Vue 时干了啥

Vue2源码梳理：在 import Vue 时干了啥

分析导入入口 在Web应用的 Vue.js 构建过程的 Runtime Compiler 版本下，我们重点关注这个版本它的入口是 src/platforms/web/entry-runtime-with-compiler.js 1 ) entry-runtime-with-compiler.js 入口文件 现在分析一下在 import Vue 的时候，都执行了…
阅读更多...
用户行为分析遇到的问题-ubantu16,hadoop3.1.3

用户行为分析遇到的问题-ubantu16,hadoop3.1.3

用户行为分析传送门 我的版本 ubantu16 hadoop 3.1.3 habse 2.2.2 hive3.1.3 zookeeper3.8.3 sqoop 1.46/1.47 我sqoop把MySQL数据往hbase导数据时候有问题 重磅：大数据课程实验案例：网站用户行为分析（免费共享） 用户行为分析-小…
阅读更多...
5G+云渲染技术：将如何快速推进XR和元宇宙？

5G+云渲染技术：将如何快速推进XR和元宇宙？

XR（扩展现实）领域正在以惊人的速度增长。目前，到 2024 年，一些专家表示这个行业的价值将达到 3000 亿美元。 这个行业发展如此迅速的部分原因是 XR 将在商业环境中的带来巨大利益。近年来，很多企业遇到了将增强现实和…
阅读更多...
RabbitMQ不公平分发问题分析及问题解决

RabbitMQ不公平分发问题分析及问题解决

1.不公平分发 1.1 不公平分发策略是什么？ 在 RabbitMQ 中，不公平分发（Unfair Dispatch）是指当多个消费者（Consumers）同时订阅同一个队列（Queue）时，消息的分发机制是不公…
阅读更多...
最新文章

Copyright @ 2022~2023