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 = {

Reply via email to