[INLONG-11372][SDK] Fix LocalTimeFunctionTest may fail in some situat…

…ion (#11374)
apache · Oct 21, 2024 · 40e0d12 · 40e0d12
1 parent 7cb5f15
commit 40e0d12
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...ain/java/org/apache/inlong/sdk/transform/process/function/temporal/LocalTimeFunction.java b/...ain/java/org/apache/inlong/sdk/transform/process/function/temporal/LocalTimeFunction.java
@@ -28,6 +28,7 @@
 
 import java.time.LocalTime;
 import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
 
 /**
  * LocalTimeFunction  ->  localTime([timeZoneStr])
@@ -55,11 +56,12 @@ public LocalTimeFunction(Function expr) {
 
     @Override
     public Object parse(SourceData sourceData, int rowIndex, Context context) {
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("HH:mm:ss");
         if (stringParser != null) {
             String zoneString = OperatorTools.parseString(stringParser.parse(sourceData, rowIndex, context));
-            return LocalTime.now(ZoneId.of(zoneString)).withNano(0);
+            return LocalTime.now(ZoneId.of(zoneString)).withNano(0).format(formatter);
         } else {
-            return LocalTime.now(ZoneId.systemDefault()).withNano(0);
+            return LocalTime.now(ZoneId.systemDefault()).withNano(0).format(formatter);
         }
     }
 }