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

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

news 文章来源：https://blog.csdn.net/sunlen/article/details/135070387 2024/11/18 14:40:12

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

CPU缓存一致性问题

什么是可见性问题？ Further Reading ：什么是可见性问题？ 缓存一致性 内存一致性 内存可见性 顺序一致性区别 CPU缓存一致性问题 由于CPU缓存的出现，很好地解决了处理器与内存速度之间的矛盾，极大地提高了CPU的吞吐能…...

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

35道HTML高频题整理(附答案背诵版)

1、简述 HTML5 新特性 &#xff1f; HTML5 是 HTML 的最新版本&#xff0c;它引入了很多新的特性和元素&#xff0c;以提供更丰富的网页内容和更好的用户体验。以下是一些主要的新特性&#xff1a; 语义元素&#xff1a;HTML5 引入了新的语义元素&#xff0c;像 <article&g…...

编程日记 2023/12/22 2:28:01

【powershell】Windows环境powershell 运维之历史文件压缩清理

&#x1f984; 个人主页——&#x1f390;开着拖拉机回家_Linux,大数据运维-CSDN博客 &#x1f390;✨&#x1f341; &#x1fa81;&#x1f341;&#x1fa81;&#x1f341;&#x1fa81;&#x1f341;&#x1fa81;&#x1f341; &#x1fa81;&#x1f341;&#x1fa81;&am…...

编程日记 2023/12/22 2:26:00

【Linux】Linux线程概念和线程控制

文章目录 一、Linux线程概念1.什么是线程2.线程的优缺点3.线程异常4.线程用途5.Linux进程VS线程 二、线程控制1.线程创建2.线程终止3.线程等待4.线程分离 一、Linux线程概念 1.什么是线程 线程是进程内的一个执行流。 我们知道&#xff0c;一个进程会有对应的PCB&#xff0c;…...

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

Flink cdc3.0同步实例（动态变更表结构、分库分表同步）

文章目录 前言准备flink环境docker构建mysql、doris环境数据准备 通过 FlinkCDC cli 提交任务整库同步同步变更路由变更路由表结构不一致无法同步 结尾 前言 最近Flink CDC 3.0发布&#xff0c; 不仅提供基础的数据同步能力。schema 变更自动同步、整库同步、分库分表等增强功…...

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

国产Apple Find My认证芯片哪里找，伦茨科技ST17H6x芯片可以帮到您

深圳市伦茨科技有限公司&#xff08;以下简称“伦茨科技”&#xff09;发布ST17H6x Soc平台。成为继Nordic之后全球第二家取得Apple Find My「查找」认证的芯片厂家&#xff0c;该平台提供可通过Apple Find My认证的Apple查找&#xff08;Find My&#xff09;功能集成解决方案。…...

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

肺癌相关知识

写在前面 大概想了解下肺癌相关的知识&#xff0c;开此贴做记录&#xff0c;看看后续有没有相关的生信文章思路。 综述 文章名期刊影响因子Lung cancer immunotherapy: progress, pitfalls, and promisesMol Cancer37.3 常见治疗手段有surgery, radiation therapy, chemoth…...

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

ChimeraX使用教程-安装及基本操作

ChimeraX使用教程-安装及基本操作 1、访问https://www.cgl.ucsf.edu/chimerax/download.html进行下载&#xff0c;然后安装 安装完成后&#xff0c;显示界面 2、基本操作 1、点击file&#xff0c;导入 .PDB 文件。 &#xff08;注&#xff1a;在 alphafold在线预测蛋白》点…...

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

【小黑嵌入式系统第十一课】μC/OS-III程序设计基础（一）——任务设计、任务管理（创建基本状态内部任务）、任务调度、系统函数

上一课&#xff1a; 【小黑嵌入式系统第十课】μC/OS-III概况——实时操作系统的特点、基本概念&#xff08;内核&任务&中断&#xff09;、与硬件的关系&实现 文章目录 一、任务设计1.1 任务概述1.2 任务的类型1.2.1 单次执行类任务&#xff08;运行至完成型&#…...

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

Redis一些常用的技术

文章目录 第1关&#xff1a;Redis 事务与锁机制第2关&#xff1a;流水线第3关&#xff1a;发布订阅第4关&#xff1a;超时命令第5关&#xff1a;使用Lua语言 第1关&#xff1a;Redis 事务与锁机制 编程要求 根据提示&#xff0c;在右侧编辑器Begin-End补充代码&#xff0c;根据…...

编程日记 2023/12/22 2:04:37

如何自己做加盟网站/企业网站seo案例

第七章 指针7 &#xff0e;1 选择题1&#xff0e; 若有说明&#xff1a;int a 2, *p &a, *q p;&#xff0c;则以下非法的赋值语句是 (D)。A&#xff0e; p q; B&#xff0e; *p *q; C&#xff0e; a *q; D&#xff0e; q a;a是整型数&#xff0c;int *p&#xff0c;*q定义了…...

编程日记 2024/11/18 13:36:25

做家政网站公司名称/seo优化软件哪个好

Idea 的 task server 配置为 Gitlab 个人站点 http://ronnie.wang 找到配置窗口&#xff0c;Preferences -> Tools -> Tasks -> Servers 点击加号&#xff0c;添加 Gitlab 点击增加之后的条目&#xff0c;可以看到下面的配置项 在 Server URL 填 Gitlab 服务器的…...

编程日记 2024/11/18 12:00:58

做网站容易挣钱吗/网络营销策划方案书范文

实现一个对整形数组的冒泡排序 #include<stdio.h> #include<stdlib.h> void bubblesort(int arr[], int size){ //数组若被传参会隐式成指针. //升序排列for (int bound 0; bound < size; bound){//此处的bound是边界,[0,bound)是已完成排序区间,[bound,size)…...

编程日记 2024/11/18 11:42:31

响应式网站的建设/广告联盟下载app

链接: 源代码下载地址 下面展示 代码 爬取上海交通大学软科中国大学排名import requests from bs4 import BeautifulSoupif __name__ "__main__":destinationPath "html信息.txt"allUniv []# headers{User-Agent:Mozilla/5.0}url http://www.shanghai…...

编程日记 2024/11/18 4:56:07

mysql 大型网站开发/成品影视app开发

通常,说到Hook键盘鼠标,总需要一大堆代码,涉及各种不明白的API.而在DSAPI中,可以说已经把勾子简化到不能再简化的地步.甚至不需要任何示例代码即会使用.那么如何实现呢? Private WithEvents HK As New DSAPI.键盘鼠标钩子注意上面带了WithEvent. 写完上面那句后,即可选择该HK,…...

编程日记 2024/11/18 0:00:54

网络营销薪酬公司/seo优化网站的手段

Git更新远程仓库代码到本地分支 一句代码解决 今天原本用的电脑被拿去维修了 换了另外一台电脑 刚好遇到这样一个问题 需要在新的这台电脑上把远程仓库上的代码拉下来 看了官方文档说用 git fetch 来实现 觉得挺麻烦的 发现了只用写一句命令就可以解决的方法 解决方案 使用 gi…...

编程日记 2024/11/17 23:49:44