我正在使用以下代码在Java中读取hadoop序列文件
SequenceFile.Reader reader = new SequenceFile.Reader(conf, SequenceFile.Reader.file(fileStatus.getPath()));
MyWritable1 key = (MyWritable1) ReflectionUtils.newInstance(reader.getKeyClass(), conf);
MyWritable2 value = (MyWritable2) ReflectionUtils.newInstance(reader.getValueClass(), conf);
while(reader.next(key, value)){ //<- exception on this line
//some code
}
而且我正在异常(exception)
"java.io.IOException: some.package.MyWritable1@4142e91 read 59 bytes, should read 231"
我正在将完全相同的类MyWritable1和MyWritable2的文件键值对写入。
这里可能是什么问题？赞赏任何提示
最佳答案
我发现了一个错误。它在MyWritable1 readFields函数中
关于java - 读取hadoop序列文件时出现IOException，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/42054024/