[doris-spark-connector] branch master updated: Fix print the password in debug log (#110)

[diwu]

This is an automated email from the ASF dual-hosted git repository.

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new eb113b7  Fix print the password in debug log (#110)
eb113b7 is described below

commit eb113b792e26f4becf28e793654c540b7f73b607
Author: ZhangJian He <shoot...@gmail.com>
AuthorDate: Tue Jun 13 14:44:04 2023 +0800

    Fix print the password in debug log (#110)
---
 .../src/main/java/org/apache/doris/spark/backend/BackendClient.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java
 
b/spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java
index 17bc8c3..aaafe09 100644
--- 
a/spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java
+++ 
b/spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java
@@ -120,7 +120,11 @@ public class BackendClient {
      * @throws ConnectedFailedException throw if cannot connect to Doris BE
      */
     public TScanOpenResult openScanner(TScanOpenParams openParams) throws 
ConnectedFailedException {
-        logger.debug("OpenScanner to '{}', parameter is '{}'.", routing, 
openParams);
+        if (logger.isDebugEnabled()) {
+            TScanOpenParams logParams = new TScanOpenParams(openParams);
+            logParams.setPasswd("********");
+            logger.debug("OpenScanner to '{}', parameter is '{}'.", routing, 
logParams);
+        }
         if (!isConnected) {
             open();
         }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org