update

apache · Sep 25, 2024 · 4245cfd · 4245cfd
1 parent 0920a30
commit 4245cfd
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/spark-doris-connector/src/test/java/org/apache/doris/spark/serialization/TestRowBatch.java b/spark-doris-connector/src/test/java/org/apache/doris/spark/serialization/TestRowBatch.java
@@ -1280,13 +1280,22 @@ public void timestampVector() throws IOException, DorisException {
         Assert.assertEquals(next.size(), 6);
         Assert.assertEquals(
                 next.get(0),
-                "2024-07-25 15:22:23.586123");
+                LocalDateTime.of(2024, 7, 25, 15, 22, 23, 586123000)
+                        .atZone(ZoneId.of("UTC+8"))
+                        .withZoneSameInstant(ZoneId.systemDefault())
+                        .toLocalDateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSSSSS")));
         Assert.assertEquals(
                 next.get(1),
-                "2024-07-25 15:22:23.586");
+                LocalDateTime.of(2024, 7, 25, 15, 22, 23, 586000000)
+                        .atZone(ZoneId.of("UTC+8"))
+                        .withZoneSameInstant(ZoneId.systemDefault())
+                        .toLocalDateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")));
         Assert.assertEquals(
                 next.get(2),
-                "2024-07-25 15:22:23");
+                LocalDateTime.of(2024, 7, 25, 15, 22, 23, 0)
+                        .atZone(ZoneId.of("UTC+8"))
+                        .withZoneSameInstant(ZoneId.systemDefault())
+                        .toLocalDateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
         Assert.assertEquals(
                 next.get(3),
                 LocalDateTime.of(2024, 7, 25, 15, 22, 23, 586123000)