From b443db6e3ebb18cf63f098dbefe6873ddc05b384 Mon Sep 17 00:00:00 2001
From: caoliang-web <71004656+caoliang-web@users.noreply.github.com>
Date: Thu, 14 Dec 2023 12:39:22 +0800
Subject: [PATCH] [fix](doriswriter)Fix multiple concurrent import label
 duplication issues #28344

---
 .../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 c3bcfadb19..22bd1f4e55 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
+}