Skip to content

Commit bf46340

Browse files
committed
address comments
1 parent 6ba223b commit bf46340

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

fluss-lake/fluss-lake-paimon/src/test/java/com/alibaba/fluss/lake/paimon/tiering/FlussRecordAsPaimonRowTest.java

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -57,8 +57,8 @@ void testLogTableRecordAllTypes() {
5757
new org.apache.paimon.types.VarCharType(),
5858
new org.apache.paimon.types.DecimalType(5, 2),
5959
new org.apache.paimon.types.DecimalType(20, 0),
60-
new org.apache.paimon.types.LocalZonedTimestampType(3),
61-
new org.apache.paimon.types.TimestampType(3),
60+
new org.apache.paimon.types.LocalZonedTimestampType(6),
61+
new org.apache.paimon.types.TimestampType(6),
6262
new org.apache.paimon.types.BinaryType(),
6363
new org.apache.paimon.types.VarCharType());
6464
FlussRecordAsPaimonRow flussRecordAsPaimonRow =
@@ -76,8 +76,8 @@ void testLogTableRecordAllTypes() {
7676
genericRow.setField(7, BinaryString.fromString("string"));
7777
genericRow.setField(8, Decimal.fromUnscaledLong(9, 5, 2));
7878
genericRow.setField(9, Decimal.fromBigDecimal(new BigDecimal(10), 20, 0));
79-
genericRow.setField(10, TimestampLtz.fromEpochMillis(1698235273182L));
80-
genericRow.setField(11, TimestampNtz.fromMillis(1698235273182L, 45678));
79+
genericRow.setField(10, TimestampLtz.fromEpochMillis(1698235273182L, 5678));
80+
genericRow.setField(11, TimestampNtz.fromMillis(1698235273182L, 5678));
8181
genericRow.setField(12, new byte[] {1, 2, 3, 4});
8282
genericRow.setField(13, null);
8383
LogRecord logRecord = new GenericRecord(logOffset, timeStamp, APPEND_ONLY, genericRow);
@@ -96,10 +96,14 @@ void testLogTableRecordAllTypes() {
9696
.isEqualTo(new BigDecimal("0.09"));
9797
assertThat(flussRecordAsPaimonRow.getDecimal(9, 20, 0).toBigDecimal())
9898
.isEqualTo(new BigDecimal(10));
99-
assertThat(flussRecordAsPaimonRow.getTimestamp(10, 3).getMillisecond())
99+
assertThat(flussRecordAsPaimonRow.getTimestamp(10, 6).getMillisecond())
100100
.isEqualTo(1698235273182L);
101+
assertThat(flussRecordAsPaimonRow.getTimestamp(10, 6).getNanoOfMillisecond())
102+
.isEqualTo(5678);
101103
assertThat(flussRecordAsPaimonRow.getTimestamp(11, 6).getMillisecond())
102104
.isEqualTo(1698235273182L);
105+
assertThat(flussRecordAsPaimonRow.getTimestamp(11, 6).getNanoOfMillisecond())
106+
.isEqualTo(5678);
103107
assertThat(flussRecordAsPaimonRow.getBinary(12)).isEqualTo(new byte[] {1, 2, 3, 4});
104108
assertThat(flussRecordAsPaimonRow.isNullAt(13)).isTrue();
105109

0 commit comments

Comments
 (0)