Explorar o código

[sparksql] Map application type to sql when opening session for sparksql (#1287)

Yuanhao %!s(int64=5) %!d(string=hai) anos
pai
achega
f634863d48
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      apps/beeswax/src/beeswax/server/hive_server2_lib.py

+ 1 - 1
apps/beeswax/src/beeswax/server/hive_server2_lib.py

@@ -692,7 +692,7 @@ class HiveServerClient(object):
 
     session = Session.objects.create(
         owner=user,
-        application=self.query_server['server_name'],
+        application='sql' if self.query_server['server_name'] == 'sparksql' else self.query_server['server_name'],
         status_code=res.status.statusCode,
         secret=encoded_status,
         guid=encoded_guid,