瀏覽代碼

HUE-9077 [ksql] Adding commandStatus message to the result

Romain 6 年之前
父節點
當前提交
fbea472423
共有 1 個文件被更改,包括 3 次插入0 次删除
  1. 3 0
      desktop/libs/kafka/src/kafka/ksql_client.py

+ 3 - 0
desktop/libs/kafka/src/kafka/ksql_client.py

@@ -124,6 +124,9 @@ class KSqlApi(object):
           data.append(['', ''])
         else:
           data.append([key, result['sourceDescription'][key]])
+    elif result['@type'] == 'currentStatus':
+      data.append([result['commandStatus']['status']])
+      data.append([result['commandStatus']['message']])
 
     columns = [[col, 'STRING'] for col in columns]