This is an automated email from the ASF dual-hosted git repository.
viirya pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/main by this push:
new 5432e03e fix: fix missing explanation for then branch in case when
(#1200)
5432e03e is described below
commit 5432e03e4c441257056638dca70f576e1e4c186b
Author: Raz Luvaton <[email protected]>
AuthorDate: Fri Dec 27 08:43:53 2024 +0200
fix: fix missing explanation for then branch in case when (#1200)
---
spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
index b33f6b5a..518fa068 100644
--- a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
+++ b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
@@ -1745,7 +1745,7 @@ object QueryPlanSerde extends Logging with
ShimQueryPlanSerde with CometExprShim
exprToProtoInternal(elements._1, inputs)
})
val thenSeq = branches.map(elements => {
- allBranches = allBranches :+ elements._1
+ allBranches = allBranches :+ elements._2
exprToProtoInternal(elements._2, inputs)
})
assert(whenSeq.length == thenSeq.length)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
