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 14df72f commit d7caeb7Copy full SHA for d7caeb7
sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryTableScanExec.scala
@@ -288,8 +288,8 @@ private[sql] case class InMemoryTableScanExec(
288
sqlContext.getConf("spark.sql.inMemoryTableScanStatistics.enable", "false").toBoolean
289
290
// Accumulators used for testing purposes
291
- lazy val readPartitions: LongAccumulator = sparkContext.longAccumulator
292
- lazy val readBatches: LongAccumulator = sparkContext.longAccumulator
+ lazy val readPartitions = sparkContext.longAccumulator
+ lazy val readBatches = sparkContext.longAccumulator
293
294
private val inMemoryPartitionPruningEnabled = sqlContext.conf.inMemoryPartitionPruning
295
0 commit comments