Skip to content

Commit 9c053d1

Browse files
authored
[hotfix] Fix IcebergRecordReaderTest#testReadLogTable fail in jdk17+ (#1837)
1 parent 18f428b commit 9c053d1

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/source/IcebergRecordReaderTest.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@
6161
import java.time.LocalDateTime;
6262
import java.time.OffsetDateTime;
6363
import java.time.ZoneOffset;
64+
import java.time.temporal.ChronoUnit;
6465
import java.util.ArrayList;
6566
import java.util.List;
6667

@@ -217,8 +218,14 @@ private List<InternalRow> writeFullTypeRows(
217218
record.setField("small_int", i % 32768);
218219
record.setField("float_val", 100.5f + i);
219220
record.setField("decimal_val", new BigDecimal(i + 100.25));
220-
record.setField("timestamp_ntz", LocalDateTime.now());
221-
record.setField("timestamp_ltz", OffsetDateTime.now(ZoneOffset.UTC));
221+
record.setField(
222+
"timestamp_ntz",
223+
LocalDateTime.of(2025, 10, 18, 10, 10, 10, 1000 * i)
224+
.truncatedTo(ChronoUnit.MICROS));
225+
record.setField(
226+
"timestamp_ltz",
227+
OffsetDateTime.of(2025, 10, 18, 10, 10, 10, 1000 * i, ZoneOffset.UTC)
228+
.truncatedTo(ChronoUnit.MICROS));
222229
record.setField("binary_data", ByteBuffer.wrap("Hello World!".getBytes()));
223230
record.setField("char_data", "char_" + i);
224231
record.setField("dt", partition);

0 commit comments

Comments
 (0)