diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExecBase.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExecBase.scala index 45fc2a0765c0..95d85dab5ced 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExecBase.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExecBase.scala @@ -71,7 +71,7 @@ trait DataSourceV2ScanExecBase extends LeafExecNode { * Shorthand for calling redact() without specifying redacting rules */ protected def redact(text: String): String = { - Utils.redact(session.sessionState.conf.stringRedactionPattern, text) + Utils.redact(conf.stringRedactionPattern, text) } override def verboseStringWithOperatorId(): String = {