From 8eacfe870f133c3eded745e643b70c105ab3d39b Mon Sep 17 00:00:00 2001
From: "aiden.dong" <782112163@qq.com>
Date: Thu, 6 Jan 2022 11:03:14 +0800
Subject: [PATCH] modify log

---
 .../scala/org/apache/doris/spark/sql/DorisSourceProvider.scala   | 1 -
 .../scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala   | 1 -
 2 files changed, 2 deletions(-)

diff --git a/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala b/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
index 95864671831f14..9b7d3f0c576bb6 100644
--- a/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
+++ b/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
@@ -115,7 +115,6 @@ private[sql] class DorisSourceProvider extends DataSourceRegister
 
           if(!rowsBuffer.isEmpty){
             logger.warn("Data that failed to load : " + dorisStreamLoader.listToString(rowsBuffer))
-            logger.warn("Failed to load data on BE: {} node ", dorisStreamLoader.getLoadUrlStr)
             throw new IOException(s"Failed to load data on BE: ${dorisStreamLoader.getLoadUrlStr} node and exceeded the max retry times.")
           }
         }
diff --git a/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala b/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala
index 5eeb97363fbdeb..6e736985adcabc 100644
--- a/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala
+++ b/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala
@@ -98,7 +98,6 @@ private[sql] class DorisStreamLoadSink(sqlContext: SQLContext, settings: SparkSe
 
           if(!rowsBuffer.isEmpty){
             logger.warn("Data that failed to load : " + dorisStreamLoader.listToString(rowsBuffer))
-            logger.warn("Failed to load data on BE: {} node ", dorisStreamLoader.getLoadUrlStr)
             throw new IOException(s"Failed to load data on BE: ${dorisStreamLoader.getLoadUrlStr} node and exceeded the max retry times.")
           }
         }