Skip to content

Commit f9ea941

Browse files
committed
clean
1 parent fa16642 commit f9ea941

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SharedThriftServer.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,11 @@ trait SharedThriftServer extends SharedSparkSession {
111111
logError("Error start hive server with Context ", e)
112112
if (hiveServer2 != null) {
113113
hiveServer2.stop()
114+
hiveServer2 = null
114115
}
116+
SessionState.detachSession()
117+
Hive.closeCurrent()
118+
throw e
115119
}
116120
}
117121
}

0 commit comments

Comments
 (0)