Skip to content

Commit 5432e03

Browse files
authored
fix: fix missing explanation for then branch in case when (apache#1200)
1 parent 58dee73 commit 5432e03

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1745,7 +1745,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
17451745
exprToProtoInternal(elements._1, inputs)
17461746
})
17471747
val thenSeq = branches.map(elements => {
1748-
allBranches = allBranches :+ elements._1
1748+
allBranches = allBranches :+ elements._2
17491749
exprToProtoInternal(elements._2, inputs)
17501750
})
17511751
assert(whenSeq.length == thenSeq.length)

0 commit comments

Comments
 (0)