Hi
java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException: org.apache.hbase.thirdparty.com.google.common.cache.CacheLoader
根据报错看，这个guava的cacheloader应该是被shade到hbase的jar包中的，你可以查看下hbase相关的jar包有没有shade进去guava的这些类。
Best,
Yichao Yang
------------------ 原始邮件 ------------------
发送时间: 2020年6月3日 23:09
主题: 回复：转发：flink1.10整合hbase测试遇到的问题
--------- 转发邮件信息 ---------
发送日期：
2020年6月3日 22:18
主题：
flink1.10整合hbase测试遇到的问题
hi!
版本说明:
flink版本1.10
HBase版本2.2.4
ZK版本3.6.1
Hadoop版本2.10.0
程序说明:
程序是简单的实现RichSourceFunction和RichSinkFunction,读取和写入hbase,程序打包后上传standalone模式的集群.
报错说明:
提交任务后,总是报如下错误(附件附文本):
或者
尝试如下:
尝试一:
flink的lib下有如下jar包:
提交的jar包中发现没有下面连个类
执行后报错
尝试二:
将guava-11.0.2.jar包移动到hadoop的lib下,再次执行依然报错
尝试结果:
反复尝试都一致报错,求大神们指点,再此先谢谢了!
Locked
