You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2019/03/29 09:51:53 UTC

[kylin] branch master updated: KYLIN-3821, add consume lag in cube detail page

This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/master by this push:
     new a5a2eda  KYLIN-3821, add consume lag in cube detail page
a5a2eda is described below

commit a5a2eda5851afd0248a3bf89361818a6f44555f3
Author: Emiya0306 <wo...@gmail.com>
AuthorDate: Fri Mar 29 17:17:19 2019 +0800

    KYLIN-3821, add consume lag in cube detail page
---
 webapp/app/js/services/streaming.js        | 1 +
 webapp/app/partials/cubes/cube_detail.html | 6 +++++-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/webapp/app/js/services/streaming.js b/webapp/app/js/services/streaming.js
index 821bbe7..b5c2900 100644
--- a/webapp/app/js/services/streaming.js
+++ b/webapp/app/js/services/streaming.js
@@ -251,6 +251,7 @@ KylinApp.factory('AdminStreamingService', ['$resource', function ($resource, con
                     receiver_cube_real_time_states.consumer_info.total_consume += partitonInfo.total_consume;
                   }
                   receiver_cube_real_time_states.partition_consume_stats = receiver_cube_real_time_states.consumer_stats.partition_consume_stats;
+                  receiver_cube_real_time_states.consume_lag = receiver_cube_real_time_states.consumer_stats.consume_lag;
                 }
                 delete receiver_cube_real_time_states.consumer_stats;
                 receiver_cube_real_time_states.receiver_state =  data.receiver_cube_real_time_states[rsId][node]['receiver_state'];
diff --git a/webapp/app/partials/cubes/cube_detail.html b/webapp/app/partials/cubes/cube_detail.html
index 67153af..ce8cc6f 100755
--- a/webapp/app/partials/cubes/cube_detail.html
+++ b/webapp/app/partials/cubes/cube_detail.html
@@ -283,10 +283,14 @@
         <div class="row">
             <div class="col-md-offset-1 col-md-3 text-right">Partitions</div>
             <div class="col-md-7" ng-if="receiverStats.partition_consume_stats">
-                <a href="javascript:void(0);" ng-repeat="partitionInfo in receiverStats.partition_consume_stats" kylinpopover placement="top" title="Partition Info" trigger="focus" content="Partition Id: {{partitionInfo.partition_id}}</br>Offset Info: {{partitionInfo.offset_info}}</br>1 Minute Rate: {{partitionInfo.one_min_rate | number:0}} msg/s</br>5 Minute Rate: {{partitionInfo.five_min_rate | number:0}} msg/s</br>15 Minute Rate: {{partitionInfo.fifteen_min_rate | number:0}} msg/s</br [...]
+                <a href="javascript:void(0);" ng-repeat="partitionInfo in receiverStats.partition_consume_stats" kylinpopover placement="top" title="Partition Info" trigger="focus" content="Partition Id: {{partitionInfo.partition_id}}</br>Offset Info: {{partitionInfo.offset_info}}</br>1 Minute Rate: {{partitionInfo.one_min_rate | number:0}} msg/s</br>5 Minute Rate: {{partitionInfo.five_min_rate | number:0}} msg/s</br>15 Minute Rate: {{partitionInfo.fifteen_min_rate | number:0}} msg/s</br [...]
                     <i class="fa fa-list-ul" style="font-size:1.5em; color:#3c8dbc; margin-right: 5px;"></i>
                 </a>
             </div>
         </div>
+        <div class="row">
+            <div class="col-md-offset-1 col-md-3 text-right">Cosume Lag</div>
+            <div class="col-md-7">{{receiverStats.consume_lag}}</div>
+        </div>
     </div>
 </script>
\ No newline at end of file