flink 查hbase出现报错  版本不一致

出现这个报错说明 flink加载配置文件时候 加载到hbase-default.xml文件 ,里边的hbase配置版本和建立flink 建表指定的hbase版本不一致

flink-sql-connector-hbase-2.2_2.12-1.14.5.jar是后边的2.2.3.版本  

前边的2.4.9 不知道是哪个jar的

查找flink目录下的jar包里边配置文件

aa=`find . -name "*.jar"`
for i in $aa
do 
echo  $i `jar tf $i  |grep -E 'hbase-site.xml|hbase-default.xml' `  >>/opt/module/tmp/hbase-site.log 
done 

发现是  hudi-flink1.14-bundle_2.12-0.11.1.jar,注释掉,flink读取hbase正常了

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐