This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 67da4b3 [Fix] fix Load Doris data failed, schema size of fetch data
is wrong (#261)
67da4b3 is described below
commit 67da4b36c54506ee9e5e02b1a647023db6c66cce
Author: caoliang-web <[email protected]>
AuthorDate: Mon Dec 11 12:06:42 2023 +0800
[Fix] fix Load Doris data failed, schema size of fetch data is wrong (#261)
---
.../src/main/java/org/apache/doris/flink/serialization/RowBatch.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 @@ public class RowBatch {
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.");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
