[incubator-doris] branch master updated: fix duplicated add delete condition (#5222)

[ya...@apache.org]

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

yangzhg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 98d8e1d  fix duplicated add delete condition (#5222)
98d8e1d is described below

commit 98d8e1d53b5e51bfa9365323fcc8faa5e865b5db
Author: Zhengguo Yang <ya...@gmail.com>
AuthorDate: Wed Jan 13 09:18:15 2021 +0800

    fix duplicated add delete condition (#5222)
---
 .../main/java/org/apache/doris/load/routineload/RoutineLoadJob.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
index 80d4954..04cdd2d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
@@ -90,6 +90,7 @@ import java.util.Optional;
 import java.util.Queue;
 import java.util.UUID;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
+import java.util.stream.Collectors;
 
 /**
  * Routine load job is a function which stream load data from streaming medium to doris.
@@ -571,7 +572,8 @@ public abstract class RoutineLoadJob extends AbstractTxnStateChangeCallback impl
         if (columnDescs == null) {
             return new ArrayList<>();
         }
-        return columnDescs;
+        // use the copy of columnDescs avoid duplicated add delete condition
+        return columnDescs.stream().collect(Collectors.toList());
     }
 
     public String getJsonPaths() {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org