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



发自我的iPhone


------------------ 原始邮件 ------------------
发件人: liunaihua521 <[email protected]&gt;
发送时间: 2020年6月3日 23:09
收件人: [email protected] <[email protected]&gt;
主题: 回复:转发:flink1.10整合hbase测试遇到的问题



                                 
              
                           
              
                                
     
 

             
--------- 转发邮件信息 ---------
                                                            发件人:                
                                       liunaihua521                             
    <[email protected]&gt;                                              
                                                        发送日期:                   
   2020年6月3日 22:18                 
                                                        发送至:                    
                                                                                
[email protected]                                         
<[email protected]&gt;                                              
                                、                                               
                               [email protected]                     
                    <[email protected]&gt;                           
                                                        
                                                         主题:                    
  flink1.10整合hbase测试遇到的问题                 
             
         
                         hi!
版本说明:
&nbsp; &nbsp; flink版本1.10
&nbsp; &nbsp; HBase版本2.2.4
&nbsp; &nbsp; ZK版本3.6.1
&nbsp; &nbsp; Hadoop版本2.10.0


程序说明:
&nbsp; &nbsp; 
程序是简单的实现RichSourceFunction和RichSinkFunction,读取和写入hbase,程序打包后上传standalone模式的集群.


报错说明:
&nbsp; &nbsp; 提交任务后,总是报如下错误(附件附文本):
&nbsp; &nbsp; 
或者
&nbsp; &nbsp; 


尝试如下:
尝试一:
&nbsp; &nbsp; flink的lib下有如下jar包:

&nbsp; &nbsp; 提交的jar包中发现没有下面连个类
&nbsp; &nbsp; 执行后报错


尝试二:
&nbsp; &nbsp; 将guava-11.0.2.jar包移动到hadoop的lib下,再次执行依然报错


尝试结果:
&nbsp; &nbsp; 反复尝试都一致报错,求大神们指点,再此先谢谢了!
     &nbsp; &nbsp;

回复