diff --git a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/SubexpressionEliminationSuite.scala b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/SubexpressionEliminationSuite.scala index 6071b4bd296c..09007659728b 100644 --- a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/SubexpressionEliminationSuite.scala +++ b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/SubexpressionEliminationSuite.scala @@ -330,13 +330,13 @@ class SubexpressionEliminationSuite extends SparkFunSuite with ExpressionEvalHel test("SPARK-38333: PlanExpression expression should skip addExprTree function in Executor") { try { // suppose we are in executor - val context1 = new TaskContextImpl(0, 0, 0, 0, 0, null, null, null, cpus = 0) + val context1 = new TaskContextImpl(0, 0, 0, 0, 0, null, null, null) TaskContext.setTaskContext(context1) val equivalence = new EquivalentExpressions val expression = DynamicPruningExpression(Exists(LocalRelation())) equivalence.addExprTree(expression) - assert(equivalence.getExprState(expression).isEmpty) + assert(equivalence.getEquivalentExprs(expression).size == 0) } finally { TaskContext.unset() }