Hbase批量加载异常(HFile版本)

3

我正在从HDFS加载数据到HBase。

 FileOutputFormat.setOutputPath(job, output);

 HTable table = new HTable(conf, tableName);
 HFileOutputFormat.configureIncrementalLoad(job, table);        
 .......    
 LoadIncrementalHFiles loader = new LoadIncrementalHFiles(config);
 loader.doBulkLoad(new Path(inPath), hTable);

以下是异常信息:

Caused by: java.lang.IllegalArgumentException: Invalid HFile version: 2099722 (expected to be between 2 and 3)
    at org.apache.hadoop.hbase.io.hfile.HFile.checkFormatVersion(HFile.java:888)
    at org.apache.hadoop.hbase.io.hfile.FixedFileTrailer.readFromStream(FixedFileTrailer.java:402)
    at org.apache.hadoop.hbase.io.hfile.HFile.pickReaderVersion(HFile.java:537)

Exception in thread "main" org.apache.hadoop.hbase.io.hfile.CorruptHFileException: Problem reading HFile Trailer from file hdfs:...
    at org.apache.hadoop.hbase.io.hfile.HFile.pickReaderVersion(HFile.java:552)
    at org.apache.hadoop.hbase.io.hfile.HFile.createReader(HFile.java:595)

你能给些建议吗?

提前感谢!

1个回答

1

你尝试运行了吗:

hbase org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles pathToHFiles tableName


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接