Skip to content

Commit 2c6849a

Browse files
committed
Address review comment: add code comment
1 parent 4082525 commit 2c6849a

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

sql/core/src/test/scala/org/apache/spark/sql/InjectRuntimeFilterSuite.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -206,6 +206,8 @@ class InjectRuntimeFilterSuite extends QueryTest with SQLTestUtils with SharedSp
206206
sql("analyze table bf5part compute statistics for columns a5, b5, c5, d5, e5, f5")
207207
sql("analyze table bf5filtered compute statistics for columns a5, b5, c5, d5, e5, f5")
208208

209+
// Tests depend on intermediate results that would otherwise be cleaned up when
210+
// shuffle clean up is enabled, causing test failures.
209211
conf.setConf(SQLConf.CLASSIC_SHUFFLE_DEPENDENCY_FILE_CLEANUP_ENABLED, false)
210212
// `MergeScalarSubqueries` can duplicate subqueries in the optimized plan and would make testing
211213
// complicated.

sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,8 @@ class AdaptiveQueryExecSuite
6969

7070
protected override def beforeAll(): Unit = {
7171
super.beforeAll()
72+
// Tests depend on intermediate results that would otherwise be cleaned up when
73+
// shuffle clean up is enabled, causing test failures.
7274
sqlConf.setConf(SQLConf.CLASSIC_SHUFFLE_DEPENDENCY_FILE_CLEANUP_ENABLED, false)
7375
}
7476

0 commit comments

Comments
 (0)