Преглед на файлове

HUE-9473 [flink] Listing table column fails with release 0.2

Romain преди 5 години
родител
ревизия
238846f9b8
променени са 1 файла, в които са добавени 3 реда и са изтрити 3 реда
  1. 3 3
      desktop/libs/notebook/src/notebook/connectors/flink_sql.py

+ 3 - 3
desktop/libs/notebook/src/notebook/connectors/flink_sql.py

@@ -248,11 +248,11 @@ class FlinkSqlApi(Api):
     resp = self.db.execute_statement(session_id=session_id, statement='USE %(database)s' % {'database': database})
     resp = self.db.execute_statement(session_id=session_id, statement='DESCRIBE %(table)s' % {'table': table})
 
-    columns = json.loads(resp['results'][0]['data'][0][0])['columns']
+    columns = resp['results'][0]['columns']
 
     return [{
-        'name': col['field_name'],
-        'type': col['field_type'],  # Types to unify
+        'name': col['name'],
+        'type': col['type'],  # Types to unify
         'comment': '',
       }
       for col in columns