[hiveserver2] Update HiveServerClient user object when opening session
@@ -572,6 +572,8 @@ class HiveServerClient:
def open_session(self, user):
+
+ self.user = user
kwargs = {
'client_protocol': beeswax_conf.THRIFT_VERSION.get() - 1,
'username': user.username, # If SASL or LDAP, it gets the username from the authentication mechanism" since it dependents on it.
