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 <[email protected]>
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 <[email protected]>
---
.../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) {
