Skip to content

Commit 29fefb5

Browse files
committed
fix 4.2 shim
1 parent 831ee7a commit 29fefb5

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

spark/src/main/spark-4.2/org/apache/comet/shims/CometExprShim.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ trait CometExprShim extends CommonStringExprs {
155155
inputs,
156156
binding)
157157
case (Literal(parser: ToTimeParser, _), "parse", args)
158-
if i.dataType.isInstanceOf[TimeType] && parser.fmt.isEmpty =>
158+
if i.dataType.isInstanceOf[TimeType] && parser.fmt.isEmpty && args.size == 1 =>
159159
val childExprs = args.map(exprToProtoInternal(_, inputs, binding))
160160
val optExpr =
161161
scalarFunctionExprToProtoWithReturnType("to_time", i.dataType, true, childExprs: _*)
@@ -167,7 +167,7 @@ trait CometExprShim extends CommonStringExprs {
167167
case TryEval(i: Invoke) =>
168168
(i.targetObject, i.functionName, i.arguments) match {
169169
case (Literal(parser: ToTimeParser, _), "parse", args)
170-
if i.dataType.isInstanceOf[TimeType] && parser.fmt.isEmpty =>
170+
if i.dataType.isInstanceOf[TimeType] && parser.fmt.isEmpty && args.size == 1 =>
171171
val childExprs = args.map(exprToProtoInternal(_, inputs, binding))
172172
val optExpr = scalarFunctionExprToProtoWithReturnType(
173173
"to_time",

0 commit comments

Comments
 (0)