You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ho...@apache.org on 2024/07/08 07:47:40 UTC
(flink) branch master updated (f41927c5a9b -> 1bf0e347966)
This is an automated email from the ASF dual-hosted git repository.
hong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from f41927c5a9b [FLINK-33211][table] support flink table lineage (#25012)
new 3dedc1aa343 FLINK-35657: use parseFloat for metric value
new 1bf0e347966 FLINK-35657: fix for all loadMetrics with parseFloat
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-runtime-web/web-dashboard/src/app/services/job-manager.service.ts | 2 +-
flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts | 2 +-
.../web-dashboard/src/app/services/task-manager.service.ts | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
(flink) 01/02: FLINK-35657: use parseFloat for metric value
Posted by ho...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3dedc1aa343cb48b0550073f155d93ffc08ad9ab
Author: Luke Chen <sh...@gmail.com>
AuthorDate: Thu Jun 20 17:43:01 2024 +0800
FLINK-35657: use parseFloat for metric value
---
flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts b/flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts
index cddefea45f3..75e1329ef48 100644
--- a/flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts
+++ b/flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts
@@ -67,7 +67,7 @@ export class MetricsService {
map(arr => {
const result: MetricMap = {};
arr.forEach(item => {
- result[item.id] = parseInt(item.value, 10);
+ result[item.id] = parseFloat(item.value);
});
return {
timestamp: Date.now(),
(flink) 02/02: FLINK-35657: fix for all loadMetrics with parseFloat
Posted by ho...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1bf0e3479664ab61f78332b0bd3fa931e85a61dc
Author: Luke Chen <sh...@gmail.com>
AuthorDate: Sat Jul 6 15:12:17 2024 +0800
FLINK-35657: fix for all loadMetrics with parseFloat
---
flink-runtime-web/web-dashboard/src/app/services/job-manager.service.ts | 2 +-
.../web-dashboard/src/app/services/task-manager.service.ts | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-runtime-web/web-dashboard/src/app/services/job-manager.service.ts b/flink-runtime-web/web-dashboard/src/app/services/job-manager.service.ts
index 28eb337222f..7a3525b6eb0 100644
--- a/flink-runtime-web/web-dashboard/src/app/services/job-manager.service.ts
+++ b/flink-runtime-web/web-dashboard/src/app/services/job-manager.service.ts
@@ -104,7 +104,7 @@ export class JobManagerService {
map(arr => {
const result: MetricMap = {};
arr.forEach(item => {
- result[item.id] = parseInt(item.value, 10);
+ result[item.id] = parseFloat(item.value);
});
return result;
})
diff --git a/flink-runtime-web/web-dashboard/src/app/services/task-manager.service.ts b/flink-runtime-web/web-dashboard/src/app/services/task-manager.service.ts
index 6e387feceec..3a8c3227ddc 100644
--- a/flink-runtime-web/web-dashboard/src/app/services/task-manager.service.ts
+++ b/flink-runtime-web/web-dashboard/src/app/services/task-manager.service.ts
@@ -108,7 +108,7 @@ export class TaskManagerService {
map(arr => {
const result: MetricMap = {};
arr.forEach(item => {
- result[item.id] = parseInt(item.value, 10);
+ result[item.id] = parseFloat(item.value);
});
return result;
})