You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by yu...@apache.org on 2025/10/20 01:48:47 UTC
(fluss) branch main updated: [hotfix] Fix IcebergRecordReaderTest#testReadLogTable fail in jdk17+ (#1837)
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 <sn...@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);