(doris-flink-connector) branch master updated: [Fix](mongdb-cdc)Schema Length Mismatch for ObjectId Non-id Fields in Collections (#588)

[diwu]

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 <76644839+kwonder0...@users.noreply.github.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org