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

[雨后彩虹]

hi,all

flink版本：最新的master分支

问题：最近需要写一个模拟HBase请求的测试类，所以需要参考 HBaseConnectorITCase这个测试类里面的 testHBaseLookupTableSource 方法，但是在运行时出现了异常，有没有知道这个怎么解决？

异常内容：

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)