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 280bd660 [Fix](mongdb-cdc)Schema Length Mismatch for ObjectId Non-id
Fields in Collections (#588)
280bd660 is described below
commit 280bd660a7b960fb6c3fd5a7abf03399ef55170c
Author: kwonder0926 <[email protected]>
AuthorDate: Mon Apr 21 14:39:51 2025 +0800
[Fix](mongdb-cdc)Schema Length Mismatch for ObjectId Non-id Fields in
Collections (#588)
---
.../main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java | 2 +-
.../org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchemaTest.java | 2 +-
.../java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBTypeTest.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java
index cb4896ab..9fa7b540 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java
@@ -62,7 +62,7 @@ public class MongoDBType {
} else if (value instanceof String) {
return DorisType.STRING;
} else if (value instanceof ObjectId) {
- return DorisType.VARCHAR + "(30)";
+ return DorisType.VARCHAR + "(36)";
} else if (value instanceof List) {
return DorisType.ARRAY + "<" + DorisType.STRING + ">";
} else if (value instanceof Decimal128) {
diff --git
a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchemaTest.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchemaTest.java
index 2f095608..9a4a9eb7 100644
---
a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchemaTest.java
+++
b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchemaTest.java
@@ -69,7 +69,7 @@ public class MongoDBSchemaTest {
MongoDBSchema mongoDBSchema = new MongoDBSchema(sampleData, "db_TEST",
"test_table", "");
assertEquals(
- "{_id=FieldSchema{name='_id', typeString='VARCHAR(30)',
defaultValue='null', comment='null'}, c_string=FieldSchema{name='c_string',
typeString='STRING', defaultValue='null', comment='null'},
c_bool=FieldSchema{name='c_bool', typeString='BOOLEAN', defaultValue='null',
comment='null'}, c_int=FieldSchema{name='c_int', typeString='INT',
defaultValue='null', comment='null'}, c_long=FieldSchema{name='c_long',
typeString='BIGINT', defaultValue='null', comment='null'}, c_double=F [...]
+ "{_id=FieldSchema{name='_id', typeString='VARCHAR(36)',
defaultValue='null', comment='null'}, c_string=FieldSchema{name='c_string',
typeString='STRING', defaultValue='null', comment='null'},
c_bool=FieldSchema{name='c_bool', typeString='BOOLEAN', defaultValue='null',
comment='null'}, c_int=FieldSchema{name='c_int', typeString='INT',
defaultValue='null', comment='null'}, c_long=FieldSchema{name='c_long',
typeString='BIGINT', defaultValue='null', comment='null'}, c_double=F [...]
mongoDBSchema.getFields().toString());
}
diff --git
a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBTypeTest.java
b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBTypeTest.java
index 4e273ab8..2701dd9a 100644
---
a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBTypeTest.java
+++
b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBTypeTest.java
@@ -55,7 +55,7 @@ public class MongoDBTypeTest {
assertEquals(DorisType.BOOLEAN, MongoDBType.toDorisType(new
Boolean(true)));
assertEquals(DorisType.STRING, MongoDBType.toDorisType("string"));
assertEquals(
- DorisType.VARCHAR + "(30)",
+ DorisType.VARCHAR + "(36)",
MongoDBType.toDorisType(new
ObjectId("66583533791a67a6f8c5a339")));
assertEquals(
"DECIMALV3(10,5)",
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
