Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/19985#discussion_r157271250
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala ---
@@ -231,6 +231,13 @@ class QueryExecution(val sparkSession: SparkSession,
val logical: LogicalPlan) {
""".stripMargin.trim
}
+ /**
+ * Redact the sensitive information in the given string.
+ */
+ private def withRedaction(message: => String): String = {
+
Utils.redact(SparkSession.getActiveSession.map(_.sparkContext.conf).orNull,
message)
--- End diff --
Why not make `Utils.redact` accept a regex parameter so that we can use
session conf?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
