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 index 6584ed21be7d8..b69e245b9fb52 100644 --- 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") {