This is an automated email from the ASF dual-hosted git repository.
zykkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 26bff2c skip table model check in multi table (#225)
26bff2c is described below
commit 26bff2cff4063a0676a75a4d94e9d3be10ab8593
Author: wudi <[email protected]>
AuthorDate: Tue Nov 7 11:47:43 2023 +0800
skip table model check in multi table (#225)
skip table model check in multi table
Co-authored-by: wudi <>
---
.../src/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 1633c96..cd02209 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 class RestService implements Serializable {
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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
