juliuszsompolski commented on a change in pull request #33743:
URL: https://github.com/apache/spark/pull/33743#discussion_r695548052
##########
File path:
sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala
##########
@@ -186,10 +186,11 @@ private[hive] class SparkExecuteStatementOperation(
override def runInternal(): Unit = {
setState(OperationState.PENDING)
logInfo(s"Submitting query '$statement' with $statementId")
+ val redactedStatement =
SparkUtils.redact(sqlContext.conf.stringRedactionPattern, statement)
Review comment:
@sarutak it would be great to also log the redactedStatement in the
logInfo one line above, otherwise the credentials needlessly leak to log4j logs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
