From b56248273f36fa3275af5075d723e179c4cf5101 Mon Sep 17 00:00:00 2001
From: wudi <>
Date: Tue, 7 Nov 2023 10:17:41 +0800
Subject: [PATCH] skip table model check in multi table

---
 .../main/java/org/apache/doris/flink/rest/RestService.java   | 5 +++++
 1 file changed, 5 insertions(+)

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) {