We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c83571a commit a43fcfbCopy full SHA for a43fcfb
core/src/main/scala/org/apache/spark/input/WholeTextFileRecordReader.scala
@@ -66,8 +66,8 @@ private[spark] class WholeTextFileRecordReader(
66
override def nextKeyValue(): Boolean = {
67
if (!processed) {
68
val conf = new Configuration
69
- val factory = new CompressionCodecFactory(conf);
70
- val codec = factory.getCodec(path); // infers from file ext.
+ val factory = new CompressionCodecFactory(conf)
+ val codec = factory.getCodec(path) // infers from file ext.
71
val fileIn = fs.open(path)
72
val innerBuffer = if (codec != null) {
73
ByteStreams.toByteArray(codec.createInputStream(fileIn))
0 commit comments