diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala index 075b4cb0e23eb..f446f12a82d2f 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala @@ -213,7 +213,7 @@ private[hive] class ClientWrapper( } /** Returns the configuration for the current session. */ - def conf: HiveConf = SessionState.get().getConf + def conf: HiveConf = state.getConf override def getConf(key: String, defaultValue: String): String = { conf.get(key, defaultValue)