File tree Expand file tree Collapse file tree 2 files changed +3
-1
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -314,6 +314,8 @@ private[hive] class HiveClientImpl(
314314 Thread .currentThread().setContextClassLoader(original)
315315 if (originState != null ) {
316316 SessionState .setCurrentSessionState(originState)
317+ } else {
318+ SessionState .detachSession()
317319 }
318320 HiveCatalogMetrics .incrementHiveClientCalls(1 )
319321 }
Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ import org.apache.spark.sql.catalyst.plans.QueryPlan
3737import org .apache .spark .sql .execution ._
3838import org .apache .spark .sql .execution .metric .SQLMetrics
3939import org .apache .spark .sql .hive ._
40- import org .apache .spark .sql .hive .client .{ HiveClient , HiveClientImpl }
40+ import org .apache .spark .sql .hive .client .HiveClientImpl
4141import org .apache .spark .sql .internal .SQLConf
4242import org .apache .spark .sql .types .{BooleanType , DataType }
4343import org .apache .spark .util .Utils
You can’t perform that action at this time.
0 commit comments