[BugFix][Connector-V2] [doris] fix: source doris have error : ErrorDescription:[arrow read error] - Index: 0, Size: 0

yangemngqi · yangemngqi · commit b32a7d76dace · 2024-12-04T17:23:44.000+08:00
diff --git a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/serialization/RowBatch.java b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/source/serialization/RowBatch.java
@@ -615,7 +615,7 @@ private void addValueToRowForArrayColumn(
         addValueToRowForAllRows(
                 col,
                 rowIndex -> {
-                    if (listVector.isNull(rowIndex)) {
+                    if (listVector.isEmpty(rowIndex)) {
                         return null;
                     }
                     List<?> listVectorObject = listVector.getObject(rowIndex);

Original file line number	Diff line number	Diff line change
`@@ -615,7 +615,7 @@ private void addValueToRowForArrayColumn(`
`615`	`615`	`addValueToRowForAllRows(`
`616`	`616`	`col,`
`617`	`617`	`rowIndex -> {`
`618`		`- if (listVector.isNull(rowIndex)) {`
	`618`	`+ if (listVector.isEmpty(rowIndex)) {`
`619`	`619`	`return null;`
`620`	`620`	`}`
`621`	`621`	`List<?> listVectorObject = listVector.getObject(rowIndex);`