nit

Author: xx789633

fluss-lake/fluss-lake-iceberg/src/test/java/com/alibaba/fluss/lake/iceberg/testutils/FlinkIcebergTieringTestBase.java

@@ -64,6 +64,8 @@
 import java.nio.ByteOrder;
 import java.nio.file.Files;
 import java.time.Duration;
+import java.time.OffsetDateTime;
+import java.time.ZoneOffset;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -323,7 +325,28 @@ protected void checkDataInIcebergPrimaryKeyTable(
             for (InternalRow row : expectedRows) {
                 Record record = records.next();
                 assertThat(record.get(0)).isEqualTo(row.getBoolean(0));
-                assertThat(record.get(1)).isEqualTo(row.getByte(1));
+                assertThat(record.get(1)).isEqualTo((int) row.getByte(1));
+                assertThat(record.get(2)).isEqualTo((int) row.getShort(2));
+                assertThat(record.get(3)).isEqualTo(row.getInt(3));
+                assertThat(record.get(4)).isEqualTo(row.getLong(4));
+                assertThat(record.get(5)).isEqualTo(row.getFloat(5));
+                assertThat(record.get(6)).isEqualTo(row.getDouble(6));
+                assertThat(record.get(7)).isEqualTo(row.getString(7).toString());
+                // Iceberg expects BigDecimal for decimal types.
+                assertThat(record.get(8)).isEqualTo(row.getDecimal(8, 5, 2).toBigDecimal());
+                assertThat(record.get(9)).isEqualTo(row.getDecimal(9, 20, 0).toBigDecimal());
+                assertThat(record.get(10))
+                        .isEqualTo(
+                                OffsetDateTime.ofInstant(
+                                        row.getTimestampLtz(10, 3).toInstant(), ZoneOffset.UTC));
+                assertThat(record.get(11))
+                        .isEqualTo(
+                                OffsetDateTime.ofInstant(
+                                        row.getTimestampLtz(11, 6).toInstant(), ZoneOffset.UTC));
+                assertThat(record.get(12)).isEqualTo(row.getTimestampNtz(12, 6).toLocalDateTime());
+                assertThat(record.get(13)).isEqualTo(row.getTimestampNtz(13, 6).toLocalDateTime());
+                // Iceberg's Record interface expects ByteBuffer for binary types.
+                assertThat(record.get(14)).isEqualTo(ByteBuffer.wrap(row.getBinary(14, 4)));
             }
             assertThat(records.hasNext()).isFalse();
         }