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