yzeng1618 commented on code in PR #4027:
URL: https://github.com/apache/flink-cdc/pull/4027#discussion_r2110666798
##########
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java:
##########
@@ -293,4 +293,15 @@ public class MySqlSourceOptions {
.defaultValue(false)
.withDescription(
"Whether to assign the unbounded chunks first
during snapshot reading phase. This might help reduce the risk of the
TaskManager experiencing an out-of-memory (OOM) error when taking a snapshot of
the largest unbounded chunk. Defaults to false.");
+
+ @Experimental
+ public static final ConfigOption<Boolean> IGNORE_NO_PRIMARY_KEY_TABLE =
+ ConfigOptions.key("ignore-no-primary-key-table")
+ .booleanType()
+ .defaultValue(false)
+ .withDescription(
+ "Whether to ignore tables without primary key.
When enabled, the connector will skip tables "
+ + "that don't have a primary key. By
default these tables will be processed, but for some "
+ + "scenarios it may be desirable to ignore
them since tables without primary keys "
+ + "might cause performance issues during
incremental snapshot.");
Review Comment:
we will skip them
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
