소스 검색

HUE-9291 [flink] Add streaming status in check status

Bit of duplication in query history.

Might have other places where we relied on just 'running'
Romain 5 년 전
부모
커밋
530e1819a3

+ 3 - 0
desktop/core/src/desktop/js/apps/notebook2/components/ko.queryHistory.js

@@ -110,6 +110,9 @@ const TEMPLATE = `
                 <!-- ko case: 'running' -->
                 <div class="history-status" data-bind="tooltip: { title: '${ I18n("Query running") }', placement: 'bottom' }"><i class="fa fa-fighter-jet fa-fw"></i></div>
                 <!-- /ko -->
+                <!-- ko case: 'streaming' -->
+                <div class="history-status" data-bind="tooltip: { title: '${ I18n("Query streaming") }', placement: 'bottom' }"><i class="fa fa-fighter-jet fa-fw"></i></div>
+                <!-- /ko -->
                 <!-- ko case: 'failed' -->
                 <div class="history-status" data-bind="tooltip: { title: '${ I18n("Query failed") }', placement: 'bottom' }"><i class="fa fa-exclamation fa-fw"></i></div>
                 <!-- /ko -->

+ 0 - 5
desktop/core/src/desktop/js/apps/notebook2/execution/executable.js

@@ -261,11 +261,6 @@ export default class Executable {
 
     this.cancellables.push(
       apiHelper.checkExecutionStatus({ executable: this }).done(async queryStatus => {
-        // TODO: Remove once backend reports 'streaming' status
-        if (queryStatus.status === EXECUTION_STATUS.running && queryStatus.data) {
-          queryStatus.status = EXECUTION_STATUS.streaming;
-        }
-
         switch (queryStatus.status) {
           case EXECUTION_STATUS.success:
             this.executeEnded = Date.now();

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

@@ -152,7 +152,7 @@ class FlinkSqlApi(Api):
         try:
           resp = self.db.fetch_status(session['id'], statement_id)
           if resp.get('status') == 'RUNNING':
-            status = 'running'
+            status = 'streaming'
             response.update(self.fetch_result(notebook, snippet, n, False))
           elif resp.get('status') == 'FINISHED':
             status = 'available'