fix test

Author: polyzos

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/utils/FlussRowToFlinkRowConverterTest.java

@@ -18,12 +18,15 @@
 package org.apache.fluss.flink.utils;
 
 import org.apache.fluss.client.table.scanner.ScanRecord;
+import org.apache.fluss.flink.row.FlinkAsFlussArray;
 import org.apache.fluss.record.ChangeType;
 import org.apache.fluss.record.LogRecord;
+import org.apache.fluss.row.BinaryString;
 import org.apache.fluss.row.InternalRow;
 import org.apache.fluss.row.indexed.IndexedRow;
 import org.apache.fluss.row.indexed.IndexedRowWriter;
 import org.apache.fluss.types.DataType;
+import org.apache.fluss.types.DataTypes;
 import org.apache.fluss.types.RowType;
 import org.apache.fluss.utils.DateTimeUtils;
 
@@ -36,6 +39,7 @@
 import java.time.LocalDate;
 import java.time.LocalTime;
 
+import static org.apache.fluss.row.BinaryString.fromString;
 import static org.apache.fluss.row.TestInternalRowGenerator.createAllRowType;
 import static org.apache.fluss.row.TestInternalRowGenerator.createAllTypes;
 import static org.apache.fluss.row.indexed.IndexedRowTest.genRecordForAllTypes;
@@ -93,7 +97,36 @@ void testConverter() throws Exception {
 
             assertThat(flinkRow.getTimestamp(17, 1).toString())
                     .isEqualTo("2023-10-25T12:01:13.182");
-            assertThat(flinkRow.isNullAt(18)).isTrue();
+            assertThat(flinkRow.getTimestamp(18, 5).toString())
+                    .isEqualTo("2023-10-25T12:01:13.182");
+
+            // array of int
+            Integer[] array1 =
+                    new FlinkAsFlussArray(flinkRow.getArray(19)).toObjectArray(DataTypes.INT());
+            assertThat(array1).isEqualTo(new Integer[] {1, 2, 3, 4, 5, -11, null, 444, 102234});
+
+            // array of float
+            Float[] array2 =
+                    new FlinkAsFlussArray(flinkRow.getArray(20)).toObjectArray(DataTypes.FLOAT());
+            assertThat(array2)
+                    .isEqualTo(
+                            new Float[] {
+                                0.1f, 1.1f, -0.5f, 6.6f, Float.MAX_VALUE, Float.MIN_VALUE
+                            });
+
+            // array of string
+            assertThat(flinkRow.getArray(21).size()).isEqualTo(3);
+            BinaryString[] stringArray1 =
+                    new FlinkAsFlussArray(flinkRow.getArray(21).getArray(0))
+                            .toObjectArray(DataTypes.STRING());
+            assertThat(stringArray1)
+                    .isEqualTo(new BinaryString[] {fromString("a"), null, fromString("c")});
+            assertThat(flinkRow.getArray(21).isNullAt(1)).isTrue();
+            BinaryString[] stringArray2 =
+                    new FlinkAsFlussArray(flinkRow.getArray(21).getArray(2))
+                            .toObjectArray(DataTypes.STRING());
+            assertThat(stringArray2)
+                    .isEqualTo(new BinaryString[] {fromString("hello"), fromString("world")});
         }
     }