change config file

apache · Sep 3, 2022 · daa82fc · daa82fc
1 parent 543bcbe
commit daa82fc
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...l-e2e/seatunnel-flink-connector-v2-e2e/src/test/resources/mongodb/mongodb_to_console.conf b/...l-e2e/seatunnel-flink-connector-v2-e2e/src/test/resources/mongodb/mongodb_to_console.conf
@@ -30,11 +30,11 @@ env {
 source {
   # This is a example source plugin **only for test and demonstrate the feature source plugin**
     MongoDB {
-        uri = "mongodb://flink_e2e_mongodb:27017/test_db?retryWrites=true&writeConcern=majority"
-        database = "test_db"
-        collection = "test_table"
-        spark.mongodb.input.partitioner = "MongoPaginateBySizePartitioner",
-        schema = "{\"id\":\"string\",\"key_aa\":\"string\",\"key_bb\":\"string\"}",
+        readconfig.uri = "mongodb://flink_e2e_mongodb:27017/test_db?retryWrites=true&writeConcern=majority"
+        readconfig.database = "test_db"
+        readconfig.collection = "test_table"
+        readconfig.spark.mongodb.input.partitioner = "MongoPaginateBySizePartitioner",
+        readconfig.schema = "{\"id\":\"string\",\"key_aa\":\"string\",\"key_bb\":\"string\"}",
         result_table_name = "test_table"
     }