File tree Expand file tree Collapse file tree
sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/autocdc Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -103,16 +103,16 @@ case class Scd1BatchProcessor(
103103 }
104104
105105 private def validateCdcMetadataColumnNotPresent (microbatchDf : DataFrame ): Unit = {
106- val sqlConf = microbatchDf.sparkSession.sessionState.conf
107- val resolver = sqlConf .resolver
106+ val microbatchSqlConf = microbatchDf.sparkSession.sessionState.conf
107+ val resolver = microbatchSqlConf .resolver
108108
109109 microbatchDf.schema.fieldNames
110110 .find(resolver(_, Scd1BatchProcessor .cdcMetadataColName))
111111 .foreach { conflictingColumnName =>
112112 throw new AnalysisException (
113113 errorClass = " AUTOCDC_RESERVED_COLUMN_NAME_CONFLICT" ,
114114 messageParameters = Map (
115- " caseSensitivity" -> CaseSensitivityLabels .of(sqlConf .caseSensitiveAnalysis),
115+ " caseSensitivity" -> CaseSensitivityLabels .of(microbatchSqlConf .caseSensitiveAnalysis),
116116 " columnName" -> conflictingColumnName,
117117 " schemaName" -> " microbatch" ,
118118 " reservedColumnName" -> Scd1BatchProcessor .cdcMetadataColName
You can’t perform that action at this time.
0 commit comments