Fix flink-tsfile-connector error

Author: HTHou

flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatIT.java

@@ -59,20 +59,20 @@ public void testBatchExecution() throws Exception {
     List<String> result = source.map(Row::toString).collect();
     Collections.sort(result);
     String[] expected = {
-      "1,1.2,20,null,2.3,11,19",
-      "10,null,20,50,25.4,10,21",
-      "11,1.4,21,null,null,null,null",
-      "12,1.2,20,51,null,null,null",
-      "14,7.2,10,11,null,null,null",
-      "15,6.2,20,21,null,null,null",
-      "16,9.2,30,31,null,null,null",
-      "2,null,20,50,25.4,10,21",
-      "3,1.4,21,null,null,null,null",
-      "4,1.2,20,51,null,null,null",
-      "6,7.2,10,11,null,null,null",
-      "7,6.2,20,21,null,null,null",
-      "8,9.2,30,31,null,null,null",
-      "9,1.2,20,null,2.3,11,19"
+      "+I[1, 1.2, 20, null, 2.3, 11, 19]",
+      "+I[10, null, 20, 50, 25.4, 10, 21]",
+      "+I[11, 1.4, 21, null, null, null, null]",
+      "+I[12, 1.2, 20, 51, null, null, null]",
+      "+I[14, 7.2, 10, 11, null, null, null]",
+      "+I[15, 6.2, 20, 21, null, null, null]",
+      "+I[16, 9.2, 30, 31, null, null, null]",
+      "+I[2, null, 20, 50, 25.4, 10, 21]",
+      "+I[3, 1.4, 21, null, null, null, null]",
+      "+I[4, 1.2, 20, 51, null, null, null]",
+      "+I[6, 7.2, 10, 11, null, null, null]",
+      "+I[7, 6.2, 20, 21, null, null, null]",
+      "+I[8, 9.2, 30, 31, null, null, null]",
+      "+I[9, 1.2, 20, null, 2.3, 11, 19]"
     };
     assertArrayEquals(expected, result.toArray());
   }
@@ -88,20 +88,20 @@ public void testStreamExecution() {
             .sorted()
             .toArray(String[]::new);
     String[] expected = {
-      "1,1.2,20,null,2.3,11,19",
-      "10,null,20,50,25.4,10,21",
-      "11,1.4,21,null,null,null,null",
-      "12,1.2,20,51,null,null,null",
-      "14,7.2,10,11,null,null,null",
-      "15,6.2,20,21,null,null,null",
-      "16,9.2,30,31,null,null,null",
-      "2,null,20,50,25.4,10,21",
-      "3,1.4,21,null,null,null,null",
-      "4,1.2,20,51,null,null,null",
-      "6,7.2,10,11,null,null,null",
-      "7,6.2,20,21,null,null,null",
-      "8,9.2,30,31,null,null,null",
-      "9,1.2,20,null,2.3,11,19"
+      "+I[1, 1.2, 20, null, 2.3, 11, 19]",
+      "+I[10, null, 20, 50, 25.4, 10, 21]",
+      "+I[11, 1.4, 21, null, null, null, null]",
+      "+I[12, 1.2, 20, 51, null, null, null]",
+      "+I[14, 7.2, 10, 11, null, null, null]",
+      "+I[15, 6.2, 20, 21, null, null, null]",
+      "+I[16, 9.2, 30, 31, null, null, null]",
+      "+I[2, null, 20, 50, 25.4, 10, 21]",
+      "+I[3, 1.4, 21, null, null, null, null]",
+      "+I[4, 1.2, 20, 51, null, null, null]",
+      "+I[6, 7.2, 10, 11, null, null, null]",
+      "+I[7, 6.2, 20, 21, null, null, null]",
+      "+I[8, 9.2, 30, 31, null, null, null]",
+      "+I[9, 1.2, 20, null, 2.3, 11, 19]"
     };
     assertArrayEquals(expected, result);
   }

tsfile/src/main/java/org/apache/iotdb/tsfile/utils/MeasurementGroup.java

@@ -20,11 +20,12 @@
 
 import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
 
+import java.io.Serializable;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
-public class MeasurementGroup {
+public class MeasurementGroup implements Serializable {
   private boolean isAligned;
   private Map<String, MeasurementSchema> measurementSchemaMap;