This is an automated email from the ASF dual-hosted git repository.
jarvis pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 3cfe8c12b9 [Improve] sink mongodb schema is not required (#8887)
3cfe8c12b9 is described below
commit 3cfe8c12b99155a4855c122b60b31260e7e09891
Author: uniding <116274818+unid...@users.noreply.github.com>
AuthorDate: Tue Mar 4 17:29:57 2025 +0800
[Improve] sink mongodb schema is not required (#8887)
Co-authored-by: zhouyq <zho...@akulaku.com>
---
docs/en/connector-v2/sink/MongoDB.md | 21 ----------------
.../seatunnel/mongodb/sink/MongodbSinkFactory.java | 7 +-----
.../resources/cdcIT/fake_cdc_sink_mongodb.conf | 7 ------
.../cdcIT/fake_cdc_upsert_sink_mongodb.conf | 7 ------
.../fake_source_to_update_mongodb.conf | 28 ----------------------
.../mongodb_matchQuery_source_to_assert.conf | 20 ----------------
.../src/test/resources/fake_source_to_mongodb.conf | 28 ----------------------
.../flatIT/fake_source_to_flat_mongodb.conf | 28 ----------------------
.../mongodb_matchProjection_source_to_assert.conf | 20 ----------------
.../mongodb_matchQuery_source_to_assert.conf | 20 ----------------
.../src/test/resources/mongodb_double_value.conf | 20 ----------------
.../src/test/resources/mongodb_null_value.conf | 21 ----------------
.../mongodb_split_key_source_to_assert.conf | 20 ----------------
.../mongodb_split_size_source_to_assert.conf | 20 ----------------
.../fake_source_to_transaction_sink_mongodb.conf | 28 ----------------------
.../fake_source_to_transaction_upsert_mongodb.conf | 28 ----------------------
.../fake_source_to_updateMode_insert_mongodb.conf | 28 ----------------------
.../updateIT/fake_source_to_update_mongodb.conf | 28 ----------------------
18 files changed, 1 insertion(+), 378 deletions(-)
diff --git a/docs/en/connector-v2/sink/MongoDB.md
b/docs/en/connector-v2/sink/MongoDB.md
index 3d08dea4b4..0f9895ab48 100644
--- a/docs/en/connector-v2/sink/MongoDB.md
+++ b/docs/en/connector-v2/sink/MongoDB.md
@@ -65,7 +65,6 @@ The following table lists the field data type mapping from
MongoDB BSON type to
| uri | String | Yes | - | The MongoDB standard
connection uri. eg.
mongodb://user:password@hosts:27017/database?readPreference=secondary&slaveOk=true.
|
| database | String | Yes | - | The name of MongoDB
database to read or write.
|
| collection | String | Yes | - | The name of MongoDB
collection to read or write.
|
-| schema | String | Yes | - | MongoDB's BSON and
seatunnel data structure mapping.
|
| buffer-flush.max-rows | String | No | 1000 | Specifies the
maximum number of buffered rows per batch request.
|
| buffer-flush.interval | String | No | 30000 | Specifies the
maximum interval of buffered rows per batch request, the unit is millisecond.
|
| retry.max | String | No | 3 | Specifies the max
number of retry if writing records to database failed.
|
@@ -113,12 +112,6 @@ sink {
uri = mongodb://user:password@127.0.0.1:27017
database = "test"
collection = "test"
- schema = {
- fields {
- _id = string
- c_bigint = bigint
- }
- }
}
}
```
@@ -175,13 +168,6 @@ sink {
collection = "users"
buffer-flush.max-rows = 2000
buffer-flush.interval = 1000
- schema = {
- fields {
- _id = string
- id = bigint
- status = string
- }
- }
}
}
```
@@ -208,13 +194,6 @@ sink {
collection = "users"
upsert-enable = true
primary-key = ["name","status"]
- schema = {
- fields {
- _id = string
- name = string
- status = string
- }
- }
}
}
```
diff --git
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbSinkFactory.java
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbSinkFactory.java
index be27db5997..530a12471d 100644
---
a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/sink/MongodbSinkFactory.java
@@ -18,7 +18,6 @@
package org.apache.seatunnel.connectors.seatunnel.mongodb.sink;
import org.apache.seatunnel.api.configuration.util.OptionRule;
-import org.apache.seatunnel.api.options.ConnectorCommonOptions;
import org.apache.seatunnel.api.table.factory.Factory;
import org.apache.seatunnel.api.table.factory.TableSinkFactory;
import org.apache.seatunnel.connectors.seatunnel.mongodb.config.MongodbConfig;
@@ -37,11 +36,7 @@ public class MongodbSinkFactory implements TableSinkFactory {
@Override
public OptionRule optionRule() {
return OptionRule.builder()
- .required(
- MongodbConfig.URI,
- MongodbConfig.DATABASE,
- MongodbConfig.COLLECTION,
- ConnectorCommonOptions.SCHEMA)
+ .required(MongodbConfig.URI, MongodbConfig.DATABASE,
MongodbConfig.COLLECTION)
.optional(
MongodbConfig.BUFFER_FLUSH_INTERVAL,
MongodbConfig.BUFFER_FLUSH_MAX_ROWS,
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_sink_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_sink_mongodb.conf
index 49527d0016..a5d6ba1f35 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_sink_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_sink_mongodb.conf
@@ -64,12 +64,5 @@ sink {
database = "test_db"
collection = "test_cdc_table"
primary-key = ["c_int"]
- schema = {
- fields {
- c_int = int
- name = string
- score = int
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_upsert_sink_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_upsert_sink_mongodb.conf
index 7140bfded2..4e1d935a7f 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_upsert_sink_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/cdcIT/fake_cdc_upsert_sink_mongodb.conf
@@ -77,12 +77,5 @@ sink {
collection = "test_cdc_table"
upsert-enable = true
primary-key = ["c_int"]
- schema = {
- fields {
- c_int = int
- name = string
- score = int
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/fake_source_to_update_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/fake_source_to_update_mongodb.conf
index a7b396b82e..4eddab702e 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/fake_source_to_update_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/fake_source_to_update_mongodb.conf
@@ -71,33 +71,5 @@ sink {
// compatible parameters
upsert-key = ["c_int"]
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- }
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/mongodb_matchQuery_source_to_assert.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/mongodb_matchQuery_source_to_assert.conf
index e7935f9e07..f16b222bc7 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/mongodb_matchQuery_source_to_assert.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/compatibleParametersIT/mongodb_matchQuery_source_to_assert.conf
@@ -66,25 +66,5 @@ sink {
database = "test_db"
collection = "test_match_op_result_db"
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- }
- }
- }
}
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/fake_source_to_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/fake_source_to_mongodb.conf
index 84cae5f66e..456ac9e30d 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/fake_source_to_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/fake_source_to_mongodb.conf
@@ -67,33 +67,5 @@ sink {
uri = "mongodb://e2e_mongodb:27017/test_db?retryWrites=true"
database = "test_db"
collection = "test_source_sink_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- }
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/flatIT/fake_source_to_flat_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/flatIT/fake_source_to_flat_mongodb.conf
index fab4a0ab5a..311e0539ca 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/flatIT/fake_source_to_flat_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/flatIT/fake_source_to_flat_mongodb.conf
@@ -67,33 +67,5 @@ sink {
database = "test_db"
collection = "test_flat_table"
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- }
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchProjection_source_to_assert.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchProjection_source_to_assert.conf
index 837b7aa6ce..07e45375d2 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchProjection_source_to_assert.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchProjection_source_to_assert.conf
@@ -64,25 +64,5 @@ sink {
database = "test_db"
collection = "test_match_op_result_db"
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_double = double
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- }
- }
- }
}
-
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchQuery_source_to_assert.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchQuery_source_to_assert.conf
index 43426568fa..3616900268 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchQuery_source_to_assert.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/matchIT/mongodb_matchQuery_source_to_assert.conf
@@ -65,25 +65,5 @@ sink {
database = "test_db"
collection = "test_match_op_result_db"
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- }
- }
- }
}
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_double_value.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_double_value.conf
index 3087d8cc8b..f037656757 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_double_value.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_double_value.conf
@@ -64,25 +64,5 @@ sink {
database = "test_db"
collection = "test_double_op_db_result"
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- }
- }
- }
}
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_null_value.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_null_value.conf
index 3b92d28a97..1561869d39 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_null_value.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/mongodb_null_value.conf
@@ -64,26 +64,5 @@ sink {
uri = "mongodb://e2e_mongodb:27017/test_db?retryWrites=true"
database = "test_db"
collection = "test_null_op_db_result"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- }
- }
- }
}
-
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_key_source_to_assert.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_key_source_to_assert.conf
index 67703410fb..186406d0e5 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_key_source_to_assert.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_key_source_to_assert.conf
@@ -65,25 +65,5 @@ sink {
database = "test_db"
collection = "test_split_op_result_db"
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- }
- }
- }
}
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_size_source_to_assert.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_size_source_to_assert.conf
index dc8dcf9e85..dd646d2e2e 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_size_source_to_assert.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/splitIT/mongodb_split_size_source_to_assert.conf
@@ -66,26 +66,6 @@ sink {
database = "test_db"
collection = "test_split_op_result_db"
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- }
- }
- }
}
}
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_sink_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_sink_mongodb.conf
index 65529c7ada..8aaf669f9b 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_sink_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_sink_mongodb.conf
@@ -70,33 +70,5 @@ sink {
database = "test_db"
collection = "test_source_transaction_sink_table"
transaction = true
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- }
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_upsert_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_upsert_mongodb.conf
index c1f9762001..f5b50cb621 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_upsert_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/transactionIT/fake_source_to_transaction_upsert_mongodb.conf
@@ -72,33 +72,5 @@ sink {
transaction = true
upsert-enable = true
primary-key = ["c_int"]
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- }
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_updateMode_insert_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_updateMode_insert_mongodb.conf
index e4687f611f..7ad3088069 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_updateMode_insert_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_updateMode_insert_mongodb.conf
@@ -70,33 +70,5 @@ sink {
upsert-enable = true
primary-key = ["c_string"]
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- }
- }
- }
}
}
\ No newline at end of file
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_update_mongodb.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_update_mongodb.conf
index decd2135b3..c3115090f7 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_update_mongodb.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mongodb-e2e/src/test/resources/updateIT/fake_source_to_update_mongodb.conf
@@ -70,33 +70,5 @@ sink {
upsert-enable = true
primary-key = ["c_int"]
plugin_input = "mongodb_table"
- schema = {
- fields {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- c_row = {
- c_map = "map<string, string>"
- c_array = "array<int>"
- c_string = string
- c_boolean = boolean
- c_int = int
- c_bigint = bigint
- c_double = double
- c_bytes = bytes
- c_date = date
- c_decimal = "decimal(33, 18)"
- c_timestamp = timestamp
- }
- }
- }
}
}
\ No newline at end of file
