You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gluten.apache.org by ma...@apache.org on 2025/05/30 19:16:35 UTC

(incubator-gluten) branch main updated: [VL] Following #9802, fix the plan listener not working for Scala 2.12 (#9815)

This is an automated email from the ASF dual-hosted git repository.

marong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git


The following commit(s) were added to refs/heads/main by this push:
     new 829fc0b0f8 [VL] Following #9802, fix the plan listener not working for Scala 2.12 (#9815)
829fc0b0f8 is described below

commit 829fc0b0f8837941ce5df22ce734863b05bd4ade
Author: Hongze Zhang <ho...@gmail.com>
AuthorDate: Fri May 30 20:16:30 2025 +0100

    [VL] Following #9802, fix the plan listener not working for Scala 2.12 (#9815)
---
 .../src/test/scala/org/apache/spark/sql/WithQueryPlanListener.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/gluten-substrait/src/test/scala/org/apache/spark/sql/WithQueryPlanListener.scala b/gluten-substrait/src/test/scala/org/apache/spark/sql/WithQueryPlanListener.scala
index a23360fd9d..f900e4503f 100644
--- a/gluten-substrait/src/test/scala/org/apache/spark/sql/WithQueryPlanListener.scala
+++ b/gluten-substrait/src/test/scala/org/apache/spark/sql/WithQueryPlanListener.scala
@@ -92,9 +92,9 @@ object WithQueryPlanListener {
 
     def invokeAll(): Unit = {
       while (plans.nonEmpty) {
-        val popped = plans.toSeq
+        val plansCopy = Seq[SparkPlan](plans.toSeq: _*)
         plans.clear()
-        popped.foreach(plan => listeners.foreach(listener => listener.apply(plan)))
+        plansCopy.foreach(plan => listeners.foreach(listener => listener.apply(plan)))
       }
     }
   }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@gluten.apache.org
For additional commands, e-mail: commits-help@gluten.apache.org