You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Anlen <29...@qq.com> on 2021/02/25 02:05:58 UTC

flink-connector-hbase-2.2 模块的测试类：HBaseConnectorITCase 运行异常

hi,all
flink版本：最新的master分支
问题：最近需要写一个模拟HBase请求的测试类，所以需要参考 HBaseConnectorITCase这个测试类里面的 testHBaseLookupTableSource&nbsp;方法，但是在运行时出现了异常，有没有知道这个怎么解决？
异常内容：
Formatting using clusterid: testClusterID
java.io.IOException: All datanodes [DatanodeInfoWithStorage[127.0.0.1:50245,DS-96ca101a-88dd-4171-84a7-1807d74885bd,DISK]] are bad. Aborting...
	at org.apache.hadoop.hdfs.DataStreamer.handleBadDatanode(DataStreamer.java:1440)
	at org.apache.hadoop.hdfs.DataStreamer.setupPipelineForAppendOrRecovery(DataStreamer.java:1383)
	at org.apache.hadoop.hdfs.DataStreamer.processDatanodeError(DataStreamer.java:1184)
	at org.apache.hadoop.hdfs.DataStreamer.run(DataStreamer.java:611)