Преглед изворни кода

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

Yuanhao пре 5 година
родитељ
комит
f634863d48
1 измењених фајлова са 1 додато и 1 уклоњено
  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,