nit

Author: xx789633

fluss-lake/fluss-lake-iceberg/src/main/java/com/alibaba/fluss/lake/iceberg/tiering/FlussRecordAsIcebergRecord.java

@@ -126,7 +126,7 @@ public Object get(int pos) {
         } else if (dataType instanceof TinyIntType) {
             return (int) internalRow.getByte(pos);
         } else if (dataType instanceof SmallIntType) {
-            return internalRow.getShort(pos);
+            return (int) internalRow.getShort(pos);
         } else if (dataType instanceof IntType) {
             return internalRow.getInt(pos);
         } else if (dataType instanceof BigIntType) {

fluss-lake/fluss-lake-iceberg/src/test/java/com/alibaba/fluss/lake/iceberg/tiering/IcebergTieringITCase.java

@@ -146,7 +146,56 @@ void testTiering() throws Exception {
 
             // then write data to the pk tables
             // write records
-            rows = Arrays.asList(row(1, "v111"), row(2, "v222"), row(3, "v333"));
+            rows =
+                    Arrays.asList(
+                            row(
+                                    true,
+                                    (byte) 100,
+                                    (short) 200,
+                                    1,
+                                    1 + 400L,
+                                    500.1f,
+                                    600.0d,
+                                    "v111",
+                                    Decimal.fromUnscaledLong(900, 5, 2),
+                                    Decimal.fromBigDecimal(new java.math.BigDecimal(1000), 20, 0),
+                                    TimestampLtz.fromEpochMillis(1698235273400L),
+                                    TimestampLtz.fromEpochMillis(1698235273400L, 7000),
+                                    TimestampNtz.fromMillis(1698235273501L),
+                                    TimestampNtz.fromMillis(1698235273501L, 8000),
+                                    new byte[] {5, 6, 7, 8}),
+                            row(
+                                    true,
+                                    (byte) 100,
+                                    (short) 200,
+                                    2,
+                                    2 + 400L,
+                                    500.1f,
+                                    600.0d,
+                                    "v222",
+                                    Decimal.fromUnscaledLong(900, 5, 2),
+                                    Decimal.fromBigDecimal(new java.math.BigDecimal(1000), 20, 0),
+                                    TimestampLtz.fromEpochMillis(1698235273400L),
+                                    TimestampLtz.fromEpochMillis(1698235273400L, 7000),
+                                    TimestampNtz.fromMillis(1698235273501L),
+                                    TimestampNtz.fromMillis(1698235273501L, 8000),
+                                    new byte[] {5, 6, 7, 8}),
+                            row(
+                                    true,
+                                    (byte) 100,
+                                    (short) 200,
+                                    3,
+                                    3 + 400L,
+                                    500.1f,
+                                    600.0d,
+                                    "v333",
+                                    Decimal.fromUnscaledLong(900, 5, 2),
+                                    Decimal.fromBigDecimal(new java.math.BigDecimal(1000), 20, 0),
+                                    TimestampLtz.fromEpochMillis(1698235273400L),
+                                    TimestampLtz.fromEpochMillis(1698235273400L, 7000),
+                                    TimestampNtz.fromMillis(1698235273501L),
+                                    TimestampNtz.fromMillis(1698235273501L, 8000),
+                                    new byte[] {5, 6, 7, 8}));
             // write records
             writeRows(t1, rows, false);