This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b443db6e3eb [fix](doriswriter)Fix multiple concurrent import label
duplication issues #28344
b443db6e3eb is described below
commit b443db6e3ebb18cf63f098dbefe6873ddc05b384
Author: caoliang-web <[email protected]>
AuthorDate: Thu Dec 14 12:39:22 2023 +0800
[fix](doriswriter)Fix multiple concurrent import label duplication issues
#28344
---
.../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]
