This is an automated email from the ASF dual-hosted git repository.

yihua pushed a commit to branch release-0.14.1-spark35-scala213
in repository https://gitbox.apache.org/repos/asf/hudi.git

commit 432dc470c7117d9c3fe8fdc1c396befe238c1f9c
Author: Lin Liu <[email protected]>
AuthorDate: Thu Feb 1 18:18:41 2024 -0800

    [HUDI-6902] Fix a test about timestamp format (#10606)
---
 .../java/org/apache/hudi/hadoop/TestHoodieParquetInputFormat.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieParquetInputFormat.java
 
b/hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieParquetInputFormat.java
index 286be418b04..6788c3a34a0 100644
--- 
a/hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieParquetInputFormat.java
+++ 
b/hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieParquetInputFormat.java
@@ -68,12 +68,14 @@ import java.io.IOException;
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Paths;
 import java.sql.Timestamp;
+import java.text.SimpleDateFormat;
 import java.time.Instant;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.Date;
 import java.util.List;
 
 import static 
org.apache.hudi.common.testutils.SchemaTestUtil.getSchemaFromResource;
@@ -813,7 +815,11 @@ public class TestHoodieParquetInputFormat {
               Instant.ofEpochMilli(testTimestampLong), ZoneOffset.UTC);
           assertEquals(Timestamp.valueOf(localDateTime).toString(), 
String.valueOf(writable.get()[0]));
         } else {
-          assertEquals(new Timestamp(testTimestampLong).toString(), 
String.valueOf(writable.get()[0]));
+          Date date = new Date();
+          date.setTime(testTimestampLong);
+          assertEquals(
+              new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(date),
+              String.valueOf(writable.get()[0]));
         }
         // test long
         assertEquals(testTimestampLong * 1000, ((LongWritable) 
writable.get()[1]).get());

Reply via email to