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 467ebfa commit a61eaedCopy full SHA for a61eaed
core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala
@@ -213,8 +213,6 @@ class HadoopRDD[K, V](
213
logInfo("Input split: " + split.inputSplit)
214
val jobConf = getJobConf()
215
216
- // Instantiate input metrics before RecordReader, because RecordReader's constructor might
217
- // read some bytes
218
val inputMetrics = new InputMetrics(DataReadMethod.Hadoop)
219
// Find a function that will return the FileSystem bytes read by this thread. Do this before
220
// creating RecordReader, because RecordReader's constructor might read some bytes
0 commit comments