org.apache.hadoop.io.serializer.SerializationFactory.getSerializer(SerializationFactory.java:73)at org.apache.hadoop.io.SequenceFile$Writer.<init>(SequenceFile.java:892)
at org.apache.h
org.apache.hadoop.io.serializer.SerializationFactory.getSerializer(SerializationFactory.java:73)at org.apache.hadoop.io.SequenceFile$Writer.<init>(SequenceFile.java:892)
at org.apache.h
问题是,如果存在SequenceFile,下面的调用将只是覆盖SequenceFile,而不是附加到它。// fs and conf are set up for HDFS, not as a LocalFileSystem keyClass, valueClass, SequenceFile.CompressionType.NONE);我
在org.apache.hadoop.io.SequenceFile$Writer.init(SequenceFile.java:1179) at org.apache.hadoop.io.SequenceFile(SequenceFile.java:1094) at org.apache.hadoop.io.SequenceFile.createWriter(SequenceFile.java:273) atorg.apache.hadoop.io.SequenceFile</