modify log

apache · Jan 6, 2022 · 8eacfe8 · 8eacfe8
1 parent 075f70c
commit 8eacfe8
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/...spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala b/...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/...spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala b/...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.")
           }
         }