You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2015/11/04 12:40:23 UTC
[2/2] flink git commit: [FLINK-2903][web-dashboard] Format numeric
values of received/sent counters.
[FLINK-2903][web-dashboard] Format numeric values of received/sent counters.
This closes #1326
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50ab9a37
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50ab9a37
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/50ab9a37
Branch: refs/heads/master
Commit: 50ab9a37ad1cf77800857eba1c41a63489f7af02
Parents: 1b2963c0
Author: Sachin Goel <sa...@gmail.com>
Authored: Wed Nov 4 16:33:03 2015 +0530
Committer: Fabian Hueske <fh...@apache.org>
Committed: Wed Nov 4 12:28:13 2015 +0100
----------------------------------------------------------------------
.../app/partials/jobs/job.plan.node-list.overview.jade | 8 ++++----
.../app/partials/jobs/job.plan.node.subtasks.jade | 8 ++++----
.../web/partials/jobs/job.plan.node-list.overview.html | 8 ++++----
.../web/partials/jobs/job.plan.node.subtasks.html | 8 ++++----
4 files changed, 16 insertions(+), 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/50ab9a37/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node-list.overview.jade
----------------------------------------------------------------------
diff --git a/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node-list.overview.jade b/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node-list.overview.jade
index b0f0a3f..d0cdb3d 100644
--- a/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node-list.overview.jade
+++ b/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node-list.overview.jade
@@ -39,10 +39,10 @@ table.table.table-body-hover.table-clickable.table-activable
span(ng-if="v.duration > -1") {{ v.duration }} ms
td.td-long {{ v.name | humanizeText }}
- td {{ v.metrics['read-bytes'] }}
- td {{ v.metrics['read-records'] }}
- td {{ v.metrics['write-bytes'] }}
- td {{ v.metrics['write-records'] }}
+ td {{ v.metrics['read-bytes'] | number }}
+ td {{ v.metrics['read-records'] | number }}
+ td {{ v.metrics['write-bytes'] | number }}
+ td {{ v.metrics['write-records'] | number }}
td
.label-group
bs-label(status="{{status}}" ng-repeat="(index, status) in stateList") {{v.tasks[status]}}
http://git-wip-us.apache.org/repos/asf/flink/blob/50ab9a37/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node.subtasks.jade
----------------------------------------------------------------------
diff --git a/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node.subtasks.jade b/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node.subtasks.jade
index bfe887d..96d9280 100644
--- a/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node.subtasks.jade
+++ b/flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.node.subtasks.jade
@@ -43,13 +43,13 @@ table.table.table-hover.table-clickable.table-activable.table-inner(ng-if="subta
span(ng-if="subtask.duration > -1") {{ subtask.duration }} ms
td
- span(ng-if="subtask.metrics['read-bytes'] > -1") {{ subtask.metrics['read-bytes'] }}
+ span(ng-if="subtask.metrics['read-bytes'] > -1") {{ subtask.metrics['read-bytes'] | number }}
td
- span(ng-if="subtask.metrics['read-records'] > -1") {{ subtask.metrics['read-records'] }}
+ span(ng-if="subtask.metrics['read-records'] > -1") {{ subtask.metrics['read-records'] | number }}
td
- span(ng-if="subtask.metrics['write-bytes'] > -1") {{ subtask.metrics['write-bytes'] }}
+ span(ng-if="subtask.metrics['write-bytes'] > -1") {{ subtask.metrics['write-bytes'] | number }}
td
- span(ng-if="subtask.metrics['write-records'] > -1") {{ subtask.metrics['write-records'] }}
+ span(ng-if="subtask.metrics['write-records'] > -1") {{ subtask.metrics['write-records'] | number }}
td {{ subtask.attempt + 1 }}
td {{ subtask.host }}
http://git-wip-us.apache.org/repos/asf/flink/blob/50ab9a37/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node-list.overview.html
----------------------------------------------------------------------
diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node-list.overview.html b/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node-list.overview.html
index 5545b8b..fda8b75 100644
--- a/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node-list.overview.html
+++ b/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node-list.overview.html
@@ -38,10 +38,10 @@ limitations under the License.
<td><span ng-if="v['end-time'] > -1">{{ v['end-time'] | amDateFormat:'YYYY-MM-DD, H:mm:ss' }}</span></td>
<td><span ng-if="v.duration > -1">{{ v.duration }} ms</span></td>
<td class="td-long">{{ v.name | humanizeText }}</td>
- <td>{{ v.metrics['read-bytes'] }}</td>
- <td>{{ v.metrics['read-records'] }}</td>
- <td>{{ v.metrics['write-bytes'] }}</td>
- <td>{{ v.metrics['write-records'] }}</td>
+ <td>{{ v.metrics['read-bytes'] | number }}</td>
+ <td>{{ v.metrics['read-records'] | number }}</td>
+ <td>{{ v.metrics['write-bytes'] | number }}</td>
+ <td>{{ v.metrics['write-records'] | number }}</td>
<td>
<div class="label-group">
<bs-label status="{{status}}" ng-repeat="(index, status) in stateList">{{v.tasks[status]}}</bs-label>
http://git-wip-us.apache.org/repos/asf/flink/blob/50ab9a37/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node.subtasks.html
----------------------------------------------------------------------
diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node.subtasks.html b/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node.subtasks.html
index 3a06aed..b549b7a 100644
--- a/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node.subtasks.html
+++ b/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node.subtasks.html
@@ -38,10 +38,10 @@ limitations under the License.
<td><span ng-if="subtask['start-time'] > -1">{{ subtask['start-time'] | amDateFormat:'YYYY-MM-DD, H:mm:ss' }}</span></td>
<td><span ng-if="subtask['end-time'] > -1">{{ subtask['end-time'] | amDateFormat:'YYYY-MM-DD, H:mm:ss' }}</span></td>
<td><span ng-if="subtask.duration > -1">{{ subtask.duration }} ms</span></td>
- <td><span ng-if="subtask.metrics['read-bytes'] > -1">{{ subtask.metrics['read-bytes'] }}</span></td>
- <td><span ng-if="subtask.metrics['read-records'] > -1">{{ subtask.metrics['read-records'] }}</span></td>
- <td><span ng-if="subtask.metrics['write-bytes'] > -1">{{ subtask.metrics['write-bytes'] }}</span></td>
- <td><span ng-if="subtask.metrics['write-records'] > -1">{{ subtask.metrics['write-records'] }}</span></td>
+ <td><span ng-if="subtask.metrics['read-bytes'] > -1">{{ subtask.metrics['read-bytes'] | number }}</span></td>
+ <td><span ng-if="subtask.metrics['read-records'] > -1">{{ subtask.metrics['read-records'] | number }}</span></td>
+ <td><span ng-if="subtask.metrics['write-bytes'] > -1">{{ subtask.metrics['write-bytes'] | number }}</span></td>
+ <td><span ng-if="subtask.metrics['write-records'] > -1">{{ subtask.metrics['write-records'] | number }}</span></td>
<td>{{ subtask.attempt + 1 }}</td>
<td>{{ subtask.host }}</td>
<td>