fix bug of jdk11

AngersZhuuuu · AngersZhuuuu · commit edaf40220402 · 2019-09-12T23:35:26.000+08:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
@@ -311,6 +311,7 @@ private[hive] class HiveClientImpl(
     val ret = try f finally {
       state.getConf.setClassLoader(originalConfLoader)
       Thread.currentThread().setContextClassLoader(original)
+      SessionState.detachSession()
       HiveCatalogMetrics.incrementHiveClientCalls(1)
     }
     ret

Original file line number	Diff line number	Diff line change
`@@ -311,6 +311,7 @@ private[hive] class HiveClientImpl(`
`311`	`311`	`val ret = try f finally {`
`312`	`312`	`state.getConf.setClassLoader(originalConfLoader)`
`313`	`313`	`Thread.currentThread().setContextClassLoader(original)`
	`314`	`+ SessionState.detachSession()`
`314`	`315`	`HiveCatalogMetrics.incrementHiveClientCalls(1)`
`315`	`316`	`}`
`316`	`317`	`ret`