revert a change

apache · May 7, 2024 · 7becda1 · 7becda1
1 parent 07c7784
commit 7becda1
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala b/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala
@@ -797,7 +797,7 @@ class CometSparkSessionExtensions
 
         // Convert native execution block by linking consecutive native operators.
         var firstNativeOp = true
-        val finalPlan = newPlan.transformDown {
+        newPlan.transformDown {
           case op: CometNativeExec =>
             if (firstNativeOp) {
               firstNativeOp = false
@@ -809,8 +809,6 @@ class CometSparkSessionExtensions
             firstNativeOp = true
             op
         }
-
-        finalPlan
       }
     }