You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2023/12/17 12:48:11 UTC
(doris) branch branch-2.0 updated: [fix](doriswriter) Fix multiple concurrent import label duplication issues #28344 (#28412)
This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 57656a4d12e [fix](doriswriter) Fix multiple concurrent import label duplication issues #28344 (#28412)
57656a4d12e is described below
commit 57656a4d12e59c5c3f1017b26b0728faf1e7b8eb
Author: caoliang-web <71...@users.noreply.github.com>
AuthorDate: Sun Dec 17 20:48:04 2023 +0800
[fix](doriswriter) Fix multiple concurrent import label duplication issues #28344 (#28412)
---
.../datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java b/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java
index c3bcfadb199..22bd1f4e55c 100644
--- a/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java
+++ b/extension/DataX/doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisStreamLoadObserver.java
@@ -127,7 +127,7 @@ public class DorisStreamLoadObserver {
"could not get the final state of label[%s].\n", label), null);
}
Map<String, Object> result = (Map<String, Object>)JSON.parse(EntityUtils.toString(respEntity));
- String labelState = (String)result.get("state");
+ String labelState = (String)result.get("data");
if (null == labelState) {
throw new IOException(String.format("Failed to flush data to Doris, Error " +
"could not get the final state of label[%s]. response[%s]\n", label, EntityUtils.toString(respEntity)), null);
@@ -263,4 +263,4 @@ public class DorisStreamLoadObserver {
return false;
}
}
-}
\ No newline at end of file
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org