vinlee19 commented on code in PR #385:
URL:
https://github.com/apache/doris-flink-connector/pull/385#discussion_r1634319088
##########
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java:
##########
@@ -131,6 +131,7 @@ private static void syncDatabase(
String multiToOneTarget = params.get("multi-to-one-target");
boolean createTableOnly = params.has("create-table-only");
boolean ignoreDefaultValue = params.has("ignore-default-value");
+ boolean mergeSameSchema = params.getBoolean("merge-same-schema", true);
Review Comment:
Currently, when the option `database test_db` is set in the following shell
command, all tables in MySQL will be synchronized to a single database in
Doris. The records from the `customer_1` and `customer_2` tables in MySQL will
be synchronized into one Doris table `customer_1`. The option
`merge-same-schema` is set to true by default to maintain compatibility with
the behavior of older versions.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
