diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java index 1633c9671..cd022097e 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java @@ -458,6 +458,11 @@ public static Schema getSchema(DorisOptions options, DorisReadOptions readOption public static boolean isUniqueKeyType(DorisOptions options, DorisReadOptions readOptions, Logger logger) throws DorisRuntimeException { + //Enable 2pc in multi-table scenario + if(StringUtils.isBlank(options.getTableIdentifier())){ + logger.info("table model verification is skipped in multi-table scenarios."); + return false; + } try { return UNIQUE_KEYS_TYPE.equals(getSchema(options, readOptions, logger).getKeysType()); } catch (Exception e) {