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 631f3cb commit ec0f160Copy full SHA for ec0f160
sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala
@@ -1064,7 +1064,7 @@ class JoinWithResourceCleanSuite extends JoinSuite with BeforeAndAfterAll {
1064
sorts
1065
}
1066
1067
- override def checkAnswer(df: => DataFrame, rows: Seq[Row]): Unit = {
+ override protected def checkAnswer(df: => DataFrame, rows: Seq[Row]): Unit = {
1068
withSQLConf(
1069
SQLConf.SORT_MERGE_JOIN_EXEC_EAGER_CLEANUP_RESOURCES.key -> "true") {
1070
checkCleanupResourceTriggered(df.queryExecution.sparkPlan)
0 commit comments