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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
