Skip to content

Commit f775f39

Browse files
committed
fixed return type
1 parent ad17e96 commit f775f39

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/datetimeFunctions.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -112,12 +112,12 @@ case class Second(child: Expression) extends UnaryExpression with ExpectsInputTy
112112
override def dataType: DataType = IntegerType
113113

114114
override protected def nullSafeEval(time: Any): Any = {
115-
time.asInstanceOf[Long] / 1000L / 1000L % 60L
115+
(time.asInstanceOf[Long] / 1000L / 1000L % 60L).toInt
116116
}
117117

118118
override protected def genCode(ctx: CodeGenContext, ev: GeneratedExpressionCode): String = {
119119
nullSafeCodeGen(ctx, ev, (time) => {
120-
s"""${ev.primitive} = (${ctx.javaType(IntegerType)}) ($time / 1000L / 1000L % 60L);"""
120+
s"""${ev.primitive} = (int) ($time / 1000L / 1000L % 60L);"""
121121
})
122122
}
123123
}

0 commit comments

Comments
 (0)