Skip to content

Commit edad5ca

Browse files
author
Ruimeng Li
committed
Fix: Schema Length Mismatch for ObjectId Non-id Fields in Collections
1 parent 2466b2b commit edad5ca

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public static String toDorisType(Object value) {
6262
} else if (value instanceof String) {
6363
return DorisType.STRING;
6464
} else if (value instanceof ObjectId) {
65-
return DorisType.VARCHAR + "(30)";
65+
return DorisType.VARCHAR + "(36)";
6666
} else if (value instanceof List) {
6767
return DorisType.ARRAY + "<" + DorisType.STRING + ">";
6868
} else if (value instanceof Decimal128) {

0 commit comments

Comments
 (0)