fix typo

LantaoJin · Oct 10, 2024 · 3e083ff · 3e083ff
1 parent 81cc9de
commit 3e083ff
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/PlannerSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/PlannerSuite.scala
@@ -266,13 +266,12 @@ class PlannerSuite extends SharedSparkSession with AdaptiveSparkPlanHelper {
     val query = testData.select($"value").limit(2).toJSON
     val planned = query.queryExecution.sparkPlan
     assert(planned.exists(_.isInstanceOf[CollectLimitExec]))
-    val t = testData.select($"value").toJSON.logicalPlan.output
   }
 
   test("SPARK-49919: TakeOrderedAndProject can be applied with toJSON") {
     val query = testData.select($"key", $"value").sort($"key").limit(2).toJSON
     val planned = query.queryExecution.executedPlan
-    assert(planned.isInstanceOf[execution.TakeOrderedAndProjectExec])
+    assert(planned.exists(_.isInstanceOf[execution.TakeOrderedAndProjectExec]))
   }
 
   test("PartitioningCollection") {