File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
spark/src/main/scala/org/apache/comet/serde Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -114,18 +114,18 @@ object CometCoalesce extends CometExpressionSerde[Coalesce] {
114114 builder.addAllThen(thenSeq.map(_.get).asJava)
115115 val elseValueExpr = exprToProtoInternal(elseValue, inputs, binding)
116116 if (elseValueExpr.isDefined) {
117- builder.setElseExpr(elseValueExpr.get)
117+ builder.setElseExpr(elseValueExpr.get)
118118 } else {
119- withInfo(expr, elseValue)
120- return None
121- }
119+ withInfo(expr, elseValue)
120+ return None
121+ }
122122 Some (
123123 ExprOuterClass .Expr
124124 .newBuilder()
125125 .setCaseWhen(builder)
126126 .build())
127127 } else {
128- withInfo(expr, branches : _* )
128+ withInfo(expr, branches.map(_._2) : _* )
129129 None
130130 }
131131 }
You can’t perform that action at this time.
0 commit comments