commit 67da4b36c54506ee9e5e02b1a647023db6c66cce
author caoliang-web <71004656+caoliang-web@users.noreply.github.com> Mon Dec 11 12:06:42 2023 +0800
committer GitHub <noreply@github.com> Mon Dec 11 12:06:42 2023 +0800
tree ff412fa58a263074d0268e7850f2021d1261cf5e
parent 82a19ab23211679ef44922f2c913c32d9c3333c1

[Fix] fix Load Doris data failed, schema size of fetch data is wrong (#261)

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
index ad8bb72..e507296 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
@@ -115,7 +115,7 @@
             this.root = arrowStreamReader.getVectorSchemaRoot();
             while (arrowStreamReader.loadNextBatch()) {
                 fieldVectors = root.getFieldVectors();
-                if (fieldVectors.size() != schema.size()) {
+                if (fieldVectors.size() > schema.size()) {
                     logger.error("Schema size '{}' is not equal to arrow field size '{}'.",
                             fieldVectors.size(), schema.size());
                     throw new DorisException("Load Doris data failed, schema size of fetch data is wrong.");