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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
