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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
