diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala index 742040e41921f..6eddbf23353f0 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala @@ -64,7 +64,7 @@ class QueryExecution( val id: Long = QueryExecution.nextExecutionId - def shuffleCleanupMode: ShuffleCleanupMode = { + val shuffleCleanupMode: ShuffleCleanupMode = { val conf = sparkSession.sessionState.conf val shuffleCleanupMode = if (conf.getConf(SQLConf.SHUFFLE_DEPENDENCY_FILE_CLEANUP_ENABLED)) {