当前位置： 首页 > news >正文

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

news 2026/3/29 1:16:28

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

相关文章：

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”异常，从报错信息来看，是由于Big…...

编程日记 2023/12/22 3:29:01

本地MinIO存储服务如何创建Buckets并实现公网访问上传文件

文章目录 前言1. 创建Buckets和Access Keys2. Linux 安装Cpolar3. 创建连接MinIO服务公网地址4. 远程调用MinIO服务小结5. 固定连接TCP公网地址6. 固定地址连接测试 前言 MinIO是一款高性能、分布式的对象存储系统，它可以100%的运行在标准硬件上，即X86等…...

编程日记 2023/12/22 3:23:57

通过https协议访问Tomcat部署并使用Shiro认证的应用跳转登到录页时协议变为http的问题

问题描述： 在最近的一个项目中，有一个存在较久，并且只在内部城域网可访问的一个使用Shiro框架进行安全管理的Java应用，该应用部署在Tomcat服务器上。起初，应用程序可以通过HTTP协议访问，一切运行都没…...

编程日记 2023/12/22 3:22:56

Backend - Django 项目创建 运行

目录 一、配置环境 二、创建 Django 项目 （一）新建文件夹 （二）打开文件夹 （三）打开运行终端 （四）创建基础项目 （五）创建app 1. 安装Django &#xf…...

编程日记 2023/12/22 3:20:53

C# .Net学习笔记—— Expression 表达式目录树

一、什么是表达式目录树 （1）Expression我们称为是表达式树，是一种数据结构体，用于存储需要计算，运算的一种结构，这种结构可以只是存储，而不进行运算。通常表达式目录树是配合Lambda一起来使用的…...

编程日记 2023/12/22 3:11:46

《论文阅读28》Unsupervised 3D Shape Completion through GAN Inversion

GAN，全称GenerativeAdversarialNetworks，中文叫生成式对抗网络。顾名思义GAN分为两个模块，生成网络以及判别网络，其中 生成网络负责根据随机向量产生图片、语音等内容，产生的内容是数据集中没有见过的，也可…...

编程日记 2023/12/22 3:09:43

一个正则快速找到在ES中使用profile的时产生慢查询的分片

在es中使用profile分析慢查询的时候，往往因为分片过多，或者因为查询条件太复杂，分析的结果几十万行。在kibana上点半天，也找不到一个耗时长的分片。 kibana上可以通过正则来匹配。其实我们只需要匹配到耗时大于10秒的请求。 检索语…...

编程日记 2023/12/22 3:08:42

链接未来：深入理解链表数据结构（一.c语言实现无头单向非循环链表）

在上一篇文章中，我们探索了顺序表这一基础的数据结构，它提供了一种有序存储数据的方法，使得数据的访 问和操作变得更加高效。想要进一步了解，大家可以移步于上一篇文章：探索顺序表：数据结构中的秩序之美 今…...

编程日记 2023/12/22 3:06:40

Python tkinter控件全集之组合选择框 ttk.ComboBox

Tkinter标准库 Tkinter是Python的标准GUI库，也是最常用的Python GUI库之一，提供了丰富的组件和功能，包括窗口、按钮、标签、文本框、列表框、滚动条、画布、菜单等，方便开发者进行图形界面的开发。Tkinter库基于Tk for Unix/Wind…...

编程日记 2023/12/22 3:05:39

Axure之中继器的使用（交互动作reperter属性Item属性）

目录 一.中继器的基本使用 二.中继器的动作（增删改查） 2.1 新增 2.2 删除 2.3 更新行 2.4 效果展示 2.5 模糊查询 三.reperter属性 在Axure中，中继器（Repeater）是一种功能强大的组件，用于创建重复…...

编程日记 2023/12/22 3:03:35

数字化医疗新篇章：构建智能医保支付购药系统

在迎接数字化医疗时代的挑战和机遇中，智能医保支付购药系统的建设显得尤为重要。本文将深入介绍如何通过先进的技术实现，构建一套智能、高效的医保支付购药系统，为全面建设健康中国贡献力量。 1. 引言 随着医疗科技的飞速发展，…...

编程日记 2023/12/22 3:02:34

11_12-Golang中的运算符

**Golang **中的运算符 主讲教师：（大地） 合作网站：www.itying.com** **（IT 营） 我的专栏：https://www.itying.com/category-79-b0.html 1、Golang 内置的运算符 算术运算符关系运算符逻辑运…...

编程日记 2023/12/22 3:01:34

k8s-ingress特性 9

TLS加密 创建证书 测试访问 auth认证 创建认证文件 rewrite重定向 进入域名时，会自动重定向到hostname.html 示例： 测试 版本的升级迭代，之前利用控制器进行滚动更新，在升级过程中无法做到快速回滚 更加平滑的升级&#xff1…...

编程日记 2023/12/22 2:58:30

【redis】redis系统实现发布订阅的标准模板

目录 简介参数配置代码模板 简介 Redis发布订阅功能是Redis的一种消息传递模式，允许多个客户端之间通过消息通道进行实时的消息传递。在发布订阅模式下，消息的发送者被称为发布者（publisher），而接收消息的客户端被称为…...

编程日记 2023/12/22 2:54:27

Python 时间日期处理库函数

标准库 datetime >>> import datetime >>> date datetime.date(2023, 12, 20) >>> print(date) 2023-12-20 >>> date datetime.datetime(2023, 12, 20) >>> print(date) 2023-12-20 00:00:00 >>> print(date.strfti…...

编程日记 2023/12/22 2:48:22

第二十二章 ： Spring Boot 集成定时任务（一）

第二十二章 ： Spring Boot 集成定时任务（一） 前言 本章知识点： 介绍使用Spring Boot内置的Scheduled注解来实现定时任务-单线程和多线程；以及介绍Quartz定时任务调度框架：简单定时调度器（Simp…...

编程日记 2023/12/22 2:46:21

关于“Python”的核心知识点整理大全32

目录 12.6.4 调整飞船的速度 settings.py ship.py alien_invasion.py 12.6.5 限制飞船的活动范围 ship.py 12.6.6 重构 check_events() game_functions.py 12.7 简单回顾 12.7.1 alien_invasion.py 12.7.2 settings.py 12.7.3 game_functions.py 12.7.4 ship.py …...

编程日记 2023/12/22 2:45:20

【krita】实时绘画 入门到精通 海报+电商+装修+人物

安装插件 首先打开comfyUI，再打开krita，出现问题提示， 打开 cd custom_nodes 输入命令 安装控件 git clone https://github.com/Acly/comfyui-tooling-nodes.git krita基础设置 设置模型 设置lora （可设置lora强度 增加更多…...

编程日记 2023/12/22 2:36:11

云原生系列2-CICD持续集成部署-GitLab和Jenkins

1、CICD持续集成部署 传统软件开发流程： 1、项目经理分配模块开发任务给开发人员（项目经理-开发） 2、每个模块单独开发完毕（开发），单元测试（测试） 3、开发完毕后，集成部…...

编程日记 2023/12/22 2:35:10

50ms时延工业相机

华睿工业相机A3504CG000 参数配置： 相机端到端理论时延：80ms 厂家同步信息，此款设备帧率上线23fps，单帧时延：43.48ms，按照一图缓存加上传输显示的话，厂家预估时延在：80ms 厂家还有…...

编程日记 2023/12/22 2:34:09

【声纳与人工智能融合——从理论前沿到自主系统实战】第四章 认知声纳与自适应信号处理（AI+SP深度融合）

目录 第四章 认知声纳与自适应信号处理（AI+SP深度融合） 4.1 认知声纳系统架构与感知循环 4.1.1 感知-规划-行动闭环设计 4.1.1.1 动态环境感知与反馈机制 4.1.1.2 基于强化学习的波形自适应选择 4.1.2 开放式认知声纳体系结构 4.1.2.1 硬件可重配置架构（SDR） 4.1.2…...

编程新知 2026/3/29 0:33:08

深入浅出：拆解Jetson上FFmpeg NVMPI硬解背后的‘黑盒子’

深入浅出：拆解Jetson上FFmpeg NVMPI硬解背后的‘黑盒子’ 在嵌入式视觉和边缘计算领域，NVIDIA Jetson平台凭借其强大的硬件编解码能力成为众多开发者的首选。但当我们使用FFmpeg的h264_nvmpi编解码器时，很少有人真正理解数据在硬件加速过程中…...

编程新知 2026/3/29 0:23:06

使用 Aspen Plus 模拟天然气的自热转化

使用aspen plus模拟天然气的自热转化自热重整工艺消耗蒸汽和氧气，将天然气转化为合成气。 事实上，自热转化工艺是放热的部分氧化（POX）工艺和内热的蒸汽甲烷转化（SMR）工艺的结合，从热力学角度中和…...

编程新知 2026/3/29 0:13:03

别再只会用QProgressBar了！用QPainterPath绘制Qt自定义进度条的完整指南

用QPainterPath实现Qt动态进度条的终极艺术 当标准进度条无法满足现代UI设计需求时，Qt的绘图系统为我们打开了无限可能。想象一下：你的应用加载界面不是单调的横条，而是会呼吸的光环、跳动的粒子流或是随音乐律动的波形——这些令人眼前一亮的…...

编程新知 2026/3/29 0:05:02

MUSE快速入门指南：5步完成英语-西班牙语词向量映射

MUSE快速入门指南：5步完成英语-西班牙语词向量映射 【免费下载链接】MUSE A library for Multilingual Unsupervised or Supervised word Embeddings 项目地址: https://gitcode.com/gh_mirrors/mu/MUSE MUSE（Multilingual Unsupervised or Super…...

编程新知 2026/3/28 23:40:55

BiliTools：革新性开源B站资源下载工具，零基础也能轻松掌握的跨平台解决方案

BiliTools：革新性开源B站资源下载工具，零基础也能轻松掌握的跨平台解决方案 【免费下载链接】BiliTools A cross-platform bilibili toolbox. 跨平台哔哩哔哩工具箱，支持视频、音乐、番剧、课程下载……持续更新 项目地址: https://gitcode…...

编程新知 2026/3/28 23:12:35

PFC 2D二维直剪代码解析与源文件分享

PFC 2D 二维直剪，代码逐行解释，提供源文件。 。 嘿，各位岩土工程或者离散元爱好者们！今天咱来唠唠PFC 2D里二维直剪的事儿，顺便把代码给大家扒一扒，逐行解释清楚，最后源文件也双手奉上&#xff…...

编程新知 2026/3/28 21:39:53

告别纸上谈兵：用Wireshark抓包实战分析FlexRay帧格式（含CRC校验）

实战解析FlexRay帧格式：用Wireshark抓包验证CRC与网络管理向量 车载工程师们常遇到这样的困境：明明熟读FlexRay协议文档，面对真实总线数据时却无从下手。本文将带您用Wireshark完成从抓包到解析的全流程实战，重点破解Header CRC校…...

编程新知 2026/3/28 21:23:46

【极简监控】告别重度存储！用 InMemoryMetricsCollector 搞定 99% 的单体应用Metrics排错

文章目录前言破局：断舍离，只关注“最近半小时”极简利器：InMemoryMetricsCollector 的设计哲学它是如何工作的？注入灵魂：结合 AI 的智能可视化结语与延伸相关前言 做系统监控这么多年下来，我们团队常常在反…...

编程新知 2026/3/28 20:49:28

AI工具使用限制解决方案：突破设备识别与权限重置完全指南

AI工具使用限制解决方案：突破设备识别与权限重置完全指南 【免费下载链接】go-cursor-help 解决Cursor在免费订阅期间出现以下提示的问题: Youve reached your trial request limit. / Too many free trial accounts used on this machine. Please upgrade to pro. …...

编程新知 2026/3/28 19:22:54