Spark java.io.EOFException:过早的EOF:没有可用的长度前缀

Question

我正在尝试阅读镶木地板文件并对其执行一些操作,并将结果保存为HDFS上的镶木地板.我是用Spark做的.在这样做的同时,我得到了以下异常.

java.io.EOFException: Premature EOF: no length prefix available
at org.apache.hadoop.hdfs.protocolPB.PBHelper.vintPrefixed(PBHelper.java:2203)
at org.apache.hadoop.hdfs.protocol.datatransfer.PipelineAck.readFields(PipelineAck.java:176)
at org.apache.hadoop.hdfs.DFSOutputStream$DataStreamer$ResponseProcessor.run(DFSOutputStream.java:867)

关于可能的原因和解决方案的任何帮助.

使用CDH 5.4.1

Answer 1

过早 EOF 代表文件过早结束。

没有发布代码，所以我无法提供更具体的解决方案，但有两种方式可能会出现此错误：

1. 如果您使用的库仍然是新的/尚未经过测试，您可能会发现它在某些极端情况下存在问题
2. 然而，更有可能的是您在代码中犯了错误。这可能像语法错误一样简单，但也可能更微妙，例如以错误的方式调用某些内容。