From 51b42804bebe5bdba2eb390b238394b18ff08799 Mon Sep 17 00:00:00 2001
From: fariel <hf@dorisdb.com>
Date: Sat, 13 Mar 2021 17:08:46 +0800
Subject: [PATCH] add debug log

---
 .../doriswriter/manager/DorisStreamLoadVisitor.java       | 8 +++-----
 .../writer/doriswriter/manager/DorisWriterManager.java    | 5 +----
 2 files changed, 4 insertions(+), 9 deletions(-)

diff --git a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisStreamLoadVisitor.java b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisStreamLoadVisitor.java
index a01b906b..90e4fdbb 100644
--- a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisStreamLoadVisitor.java
+++ b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisStreamLoadVisitor.java
@@ -1,7 +1,6 @@
 package com.dorisdb.connector.datax.plugin.writer.doriswriter.manager;
 
 import java.io.IOException;
-import java.io.Serializable;
 import java.net.HttpURLConnection;
 import java.net.URL;
 import java.nio.charset.StandardCharsets;
@@ -27,9 +26,7 @@ import java.util.List;
 import java.util.Map;
 
  
-public class DorisStreamLoadVisitor implements Serializable {
-
-    private static final long serialVersionUID = 1L;
+public class DorisStreamLoadVisitor {
 
     private static final Logger LOG = LoggerFactory.getLogger(DorisStreamLoadVisitor.class);
 
@@ -57,9 +54,10 @@ public class DorisStreamLoadVisitor implements Serializable {
         if (null == loadResult || !loadResult.containsKey(keyStatus)) {
             throw new IOException("Unable to flush data to doris: unknown result status.");
         }
+        LOG.debug(new StringBuilder("StreamLoad response:\n").append(JSON.toJSONString(loadResult)).toString());
         if (loadResult.get(keyStatus).equals("Fail")) {
             throw new IOException(
-                new StringBuilder("Failed to flush data to doris.").append(loadResult.get("Message").toString()).toString()
+                new StringBuilder("Failed to flush data to doris.\n").append(JSON.toJSONString(loadResult)).toString()
             );
         }
     }
diff --git a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisWriterManager.java b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisWriterManager.java
index 86d370a5..a5338ca9 100644
--- a/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisWriterManager.java
+++ b/doriswriter/src/main/java/com/dorisdb/connector/datax/plugin/writer/doriswriter/manager/DorisWriterManager.java
@@ -4,16 +4,13 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
-import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
 
 import com.dorisdb.connector.datax.plugin.writer.doriswriter.DorisWriterOptions;
 
-public class DorisWriterManager implements Serializable {
-
-    private static final long serialVersionUID = 1L;
+public class DorisWriterManager {
     
     private static final Logger LOG = LoggerFactory.getLogger(DorisWriterManager.class);