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 fafba7b commit 4ee25d6Copy full SHA for 4ee25d6
core/src/main/scala/org/apache/spark/rdd/HadoopRDD.scala
@@ -197,8 +197,6 @@ class HadoopRDD[K, V](
197
newInputFormat
198
}
199
200
- private val UNSPLITTABLE_FILE_SIZE_LOG_THRESHOLD = 1024 * 1024 * 1024
201
-
202
@transient private lazy val codecFactory = new CompressionCodecFactory(getJobConf())
203
204
override def getPartitions: Array[Partition] = {
0 commit comments