You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2022/09/17 14:47:27 UTC
[incubator-streampark] branch dev updated: [Bug] When Flink is started in the on yarn mode, the total task and running task indicators are not accurately obtained #1632 (#1633)
This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new e81fa89a8 [Bug] When Flink is started in the on yarn mode, the total task and running task indicators are not accurately obtained #1632 (#1633)
e81fa89a8 is described below
commit e81fa89a8b453db6768273f32e6385e8e6c8fa49
Author: macksonmu <30...@qq.com>
AuthorDate: Sat Sep 17 22:47:20 2022 +0800
[Bug] When Flink is started in the on yarn mode, the total task and running task indicators are not accurately obtained #1632 (#1633)
Co-authored-by: mucj7 <mu...@chinaunicom.cn>
---
.../org/apache/streampark/console/core/task/FlinkTrackingTask.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkTrackingTask.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkTrackingTask.java
index 4c7f1ab79..4977c8e1b 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkTrackingTask.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkTrackingTask.java
@@ -324,12 +324,11 @@ public class FlinkTrackingTask {
}
}
application.setDuration(jobOverview.getDuration());
+ application.setTotalTask(jobOverview.getTasks().getTotal());
+ application.setOverview(jobOverview.getTasks());
// get overview info at the first start time
if (STARTING_CACHE.getIfPresent(application.getId()) != null) {
- application.setTotalTask(jobOverview.getTasks().getTotal());
- application.setOverview(jobOverview.getTasks());
-
FlinkCluster flinkCluster = getFlinkCluster(application);
Overview override = httpOverview(application, flinkCluster);
if (override != null && override.getSlotsTotal() > 0) {