Hudi-FlinkSQL导入数据报错：[ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundExceptio

时间：2024-02-28 14:33:22浏览次数：25

标签：lang execute Hudi FlinkSQL hadoop ClassNotFoundException 报错 FSDataInputStream

问题描述

通过FlinkSQL创建Hudi表后，向表中插入数据报错：

[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.hadoop.fs.FSDataInputStream

解决办法

向Hudi表中写入数据时，会调用Hadoop的Jar包，但是Flink的lib目录中没有该Jar包。

需要将hadoop目录中share/hadoop/mapreduce/hadoop-mapreduce-client-core-X.X.X.jar包拷贝到Flink的lib目录中。

然后重启Flink集群，stop-cluster.sh && start-cluster.sh

标签：lang,execute,Hudi,FlinkSQL,hadoop,ClassNotFoundException,报错,FSDataInputStream
From： https://www.cnblogs.com/yeyuzhuanjia/p/18040308

oracle表空间不足报错排查及扩容
一、报错代码：Errorupdatingdatabase. Cause:java.sql.SQLException:ORA-01691:unabletoextendlobsegmentOMSP_FLOWGINE.SYS_LOB0000035445C00014$$by1024intablespaceOMSP 二、排查执行下面sql:SELECTa.tablespace_name,TRUNC(tablespace_size......
解决uniapp项目中使用vant Weapp图标组件报错问题（Module build failed from ./node_mo
解决uniapp项目中使用vantWeapp图标组件报错问题（Modulebuildfailedfrom./node_modules/postcss-loader/src/index）：https://blog.csdn.net/it_cgq/article/details/111991644?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522170909210216800225582870%2522%252C%252......
向日葵远程报错：对方正在操作鼠标，暂时无法控制
控制时被控方始终报错显示“对方正在操作鼠标，暂时无法控制”，即使重启电脑和重装向日葵也于事无补。问过向日葵工单后，得到的解决办法是：打开被控端向日葵软件，向日葵软件内--右上角三横杠--设置--安全--将被控端鼠标优先选项进行取消勾选，再发起远程即可......
【报错解决】【Mathtype】lease restart Word to load MathType addin properly
打开Mathtype安装目录例如我的C:\software\MathModel\MATHTYPE继续进入目录C:\software\MathModel\MATHTYPE\MathPage\64找到MathPage.wll复制该文件在word中查看加载项的路径，将刚才复制的文件粘贴到这个路径当中返回上一级目录，再次粘贴这个文件重启word，问题解决......
Python脚本给数据库插入数据报错： raise errorclass(errno, errval) pymysql.err.Integ
一、问题描述在SQL客户端插入数据时执行SQL语句INSERTINTOuser_xxx(id,uid,total,balance,wallet_type,ctime,utime)VALUES(0,'336448391',271,89000098,'coin',1708588247,1709007766);可以成功执行没报错；使用python脚本执行SQL语句INSERTINTOuser_xxx......
idea启动报错
ImproperlyspecifiedVMoption.Tofixtheproblem,edityourJVMoptionsandremovetheoptionsthatareobsoleteornotsupportedbythecurrentversionoftheJvM.FailedtocreateJVM,JVMPath:D:000lideaJetBrainslintelli]IDEA2020.3.3\jbr ......
Golang面试
slice扩容机制GO1.17版本及之前当新切片需要的容量cap大于两倍扩容的容量，则直接按照新切片需要的容量扩容；当原slice容量<1024的时候，新slice容量变成原来的2倍；当原slice容量>1024，进入一个循环，每次容量变成原来的1.25倍,直到大于期望容量。GO1.18之后当新切片......
npm报错：request to https://registry.npm.taobao.org failed, reason certificate has
一、报错问题：提示淘宝镜像过期二、错误提示已经告诉原因是淘宝镜像过期了！其实，早在2021年，淘宝就发文称，npm淘宝镜像已经从registry.npm.taobao.org切换到了registry.npmmirror.com。旧域名也将于2022年5月31日停止服务（不过，直到今天HTTPS证书到期才真正不能用了）三......
服务器安装CentOS7 报错/dev/root does not exist
报错内容通过u盘安装实体服务器时，找不到u盘报错解决方法在报错页面出入blkid，查看u盘盘符在安装界面按“e”修改将 vmlinuzinitrd=initrd.imginst.stage2=hd:LABEL=CentOS\xxxxquiet修改为vmlinuzinitrd=initrd.imginst.stage2=hd:/dev/sdb4quiet修改后......
解决kali上安装wine32报错
1.问题描述：解决kali上安装wine32报错，报错信息如下Thefollowingpackageshaveunmetdependencies:libglib2.0-0:i386:Depends:libpcre2-8-0:i386(>=10.22)butitisnotgoingtobeinstalledlibselinux1:i386:Depends:libpcre2-8-0:i386(>=10.22)butitisnot......

Hudi-FlinkSQL导入数据报错：[ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundExceptio

相关文章

赞助商

阅读排行