[inlong] branch master updated: [INLONG-6690][Sort] Fix the multiple migrations of Doris when batch delete was enabled (#6691)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 41f829de8 [INLONG-6690][Sort] Fix the multiple migrations of Doris 
when batch delete was enabled (#6691)
41f829de8 is described below

commit 41f829de81ef4e26fa0e24f2c0520d155f0deb9d
Author: Yizhou Yang <32808678+yizhou-y...@users.noreply.github.com>
AuthorDate: Thu Dec 1 19:33:40 2022 +0800

    [INLONG-6690][Sort] Fix the multiple migrations of Doris when batch delete 
was enabled (#6691)
---
 .../inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java      | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
 
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
index 715de5db1..13cf52323 100644
--- 
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
+++ 
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
@@ -230,11 +230,14 @@ public class DorisDynamicSchemaOutputFormat<T> extends 
RichOutputFormat<T> {
     }
 
     private boolean enableBatchDelete() {
+        if (multipleSink) {
+            return executionOptions.getEnableDelete();
+        }
         try {
             Schema schema = RestService.getSchema(options, readOptions, LOG);
             return executionOptions.getEnableDelete() || 
UNIQUE_KEYS_TYPE.equals(schema.getKeysType());
         } catch (DorisException e) {
-            throw new RuntimeException("Failed fetch doris table schema: " + 
options.getTableIdentifier(), e);
+            throw new RuntimeException("Failed fetch doris single table 
schema: " + options.getTableIdentifier(), e);
         }
     }