(fluss) branch main updated: [hotfix] Fix IcebergRecordReaderTest#testReadLogTable fail in jdk17+ (#1837)

[yuxia]

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

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 9c053d180 [hotfix] Fix IcebergRecordReaderTest#testReadLogTable fail 
in jdk17+ (#1837)
9c053d180 is described below

commit 9c053d1809dc33765a4afac107a5132c5f16b731
Author: Sergey Nuyanzin <snuyan...@confluent.io>
AuthorDate: Mon Oct 20 03:48:43 2025 +0200

    [hotfix] Fix IcebergRecordReaderTest#testReadLogTable fail in jdk17+ (#1837)
---
 .../fluss/lake/iceberg/source/IcebergRecordReaderTest.java    | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git 
a/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/source/IcebergRecordReaderTest.java
 
b/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/source/IcebergRecordReaderTest.java
index bcf559348..0ae2c049c 100644
--- 
a/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/source/IcebergRecordReaderTest.java
+++ 
b/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/source/IcebergRecordReaderTest.java
@@ -61,6 +61,7 @@ import java.nio.ByteBuffer;
 import java.time.LocalDateTime;
 import java.time.OffsetDateTime;
 import java.time.ZoneOffset;
+import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -217,8 +218,14 @@ class IcebergRecordReaderTest extends 
IcebergSourceTestBase {
             record.setField("small_int", i % 32768);
             record.setField("float_val", 100.5f + i);
             record.setField("decimal_val", new BigDecimal(i + 100.25));
-            record.setField("timestamp_ntz", LocalDateTime.now());
-            record.setField("timestamp_ltz", 
OffsetDateTime.now(ZoneOffset.UTC));
+            record.setField(
+                    "timestamp_ntz",
+                    LocalDateTime.of(2025, 10, 18, 10, 10, 10, 1000 * i)
+                            .truncatedTo(ChronoUnit.MICROS));
+            record.setField(
+                    "timestamp_ltz",
+                    OffsetDateTime.of(2025, 10, 18, 10, 10, 10, 1000 * i, 
ZoneOffset.UTC)
+                            .truncatedTo(ChronoUnit.MICROS));
             record.setField("binary_data", ByteBuffer.wrap("Hello 
World!".getBytes()));
             record.setField("char_data", "char_" + i);
             record.setField("dt", partition);