diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecutionRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecutionRDD.scala index 7373da33e12ad..0e4dc6491ef04 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecutionRDD.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecutionRDD.scala @@ -39,7 +39,7 @@ class SQLExecutionRDD( private val sqlConfigs = conf.getAllConfs private lazy val sqlConfExecutorSide = { val props = new Properties() - props.putAll(sqlConfigs.asJava) + sqlConfigs.foreach { case (k, v) => props.setProperty(k, v) } val newConf = new SQLConf() newConf.setConf(props) newConf