From 8fe703c89db9a8ebcae62bd48a880bbc5b4e926b Mon Sep 17 00:00:00 2001 From: Raz Luvaton <16746759+rluvaton@users.noreply.github.com> Date: Wed, 25 Dec 2024 15:33:14 +0200 Subject: [PATCH] fix: fix missing explanation for then branch in case when --- .../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 b33f6b5a6b..518fa06858 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)