This is an automated email from the ASF dual-hosted git repository. xxyu pushed a commit to branch kylin5 in repository https://gitbox.apache.org/repos/asf/kylin.git
commit 76dc3a616ac382768a58841fdabc240f85ec659f Author: Mingming Ge <7mmi...@gmail.com> AuthorDate: Wed Dec 14 11:08:37 2022 +0800 KYLIN-5422 fix ceil function codegen error --- .../apache/spark/sql/catalyst/expressions/KapExpresssions.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/catalyst/expressions/KapExpresssions.scala b/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/catalyst/expressions/KapExpresssions.scala index ea28802be5..08a9fa3cc0 100644 --- a/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/catalyst/expressions/KapExpresssions.scala +++ b/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/catalyst/expressions/KapExpresssions.scala @@ -550,10 +550,10 @@ case class CeilDateTime(timestamp: Expression, override def doGenCode(ctx: CodegenContext, ev: ExprCode): ExprCode = { val zid = ctx.addReferenceObj("zoneId", zoneId, classOf[ZoneId].getName) - val dtu = DateTimeUtils.getClass.getName.stripSuffix("$") - defineCodeGen(ctx, ev, (date, fmt) => { - s"""$dtu.ceilTimestamp($date, $fmt, $zid)""" - }) + codeGenHelper(ctx, ev, minLevel = DateTimeUtils.TRUNC_TO_SECOND, orderReversed = true) { + (date: String, fmt: String) => + s"ceilTimestamp($date, $fmt, $zid);" + } } override protected def withNewChildrenInternal(newLeft: Expression, newRight: Expression): Expression = {