这个是因为这个 class 不在路径中导致的。你需要确认一下这个 class 在哪个 jar 包中,这个 jar 包是否在 flink 的 lib 下




在2020年06月3日 22:52,liunaihua521<[email protected]> 写道:





--------- 转发邮件信息 ---------

发件人: liunaihua521 <[email protected]>
发送日期: 2020年6月3日 22:18
发送至: [email protected] <[email protected]> 、 
[email protected] <[email protected]>
主题: 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下,再次执行依然报错


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

回复