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 df2de6c4a4cd8..2f771d76793e5 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
@@ -164,7 +164,7 @@ private[hive] class ClientWrapper(
               s"(${retryLimit - numTries} tries remaining)", e)
           Thread.sleep(retryDelayMillis)
           try {
-            client = Hive.get(conf, true)
+            client = Hive.get(state.getConf, true)
           } catch {
             case e: Exception if causedByThrift(e) =>
               logWarning("Failed to refresh hive client, will retry.", e)