This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from aae0462cb39 [FLINK-24787][docs] Add more details of state latency
tracking documentation
new 247d4263c1a [hotfix][runtime][tests] Migrates some tests to Junit5
new 53938680abe [FLINK-28588][rest] Add blocked flag in TaskManagerInfo
and TaskManagerDetailsInfo
new 0263b55288b [FLINK-28588][rest] Add blocked task manager count and
blocked slot count in ResourceOverview and ClusterOverview
new 44c00dbb4a0 [FLINK-28588][rest] Archive all current executions in
ArchivedExecutionVertex.
new 1a48fd53bd3 [FLINK-28588][rest] MetricStore supports to store and
query metrics of multiple execution attempts of a subtask.
new f436b20429b [FLINK-28588][rest] Acquire information of all current
executions in REST handlers if applicable
The 6 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:
.../history/HistoryServerArchiveFetcher.java | 3 +-
.../src/test/resources/rest_api_v1.snapshot | 43 +++
.../executiongraph/AccessExecutionVertex.java | 9 +
.../executiongraph/ArchivedExecutionVertex.java | 26 +-
.../ArchivedSpeculativeExecutionVertex.java | 52 ---
.../executiongraph/SpeculativeExecutionVertex.java | 4 +-
.../messages/webmonitor/ClusterOverview.java | 52 ++-
.../runtime/messages/webmonitor/JobDetails.java | 98 +++++-
.../metrics/dump/MetricDumpSerialization.java | 10 +-
.../flink/runtime/metrics/dump/QueryScopeInfo.java | 28 +-
.../groups/InternalOperatorMetricGroup.java | 1 +
.../runtime/metrics/groups/TaskMetricGroup.java | 5 +-
.../runtime/resourcemanager/ResourceManager.java | 33 +-
.../runtime/resourcemanager/ResourceOverview.java | 18 +-
.../handler/job/AbstractSubtaskAttemptHandler.java | 15 +-
.../rest/handler/job/JobDetailsHandler.java | 2 +
.../rest/handler/job/JobExceptionsHandler.java | 33 +-
.../handler/job/JobVertexBackPressureHandler.java | 87 ++++-
.../rest/handler/job/JobVertexDetailsHandler.java | 17 +-
.../handler/job/JobVertexTaskManagersHandler.java | 73 +++--
.../job/SubtaskCurrentAttemptDetailsHandler.java | 19 +-
...SubtaskExecutionAttemptAccumulatorsHandler.java | 38 +--
.../job/SubtaskExecutionAttemptDetailsHandler.java | 52 +--
.../job/SubtasksAllAccumulatorsHandler.java | 32 +-
.../rest/handler/job/SubtasksTimesHandler.java | 3 +-
.../messages/ClusterOverviewWithVersion.java | 26 +-
.../handler/legacy/metrics/MetricFetcherImpl.java | 1 +
.../rest/handler/legacy/metrics/MetricStore.java | 186 +++++++++--
.../rest/handler/util/MutableIOMetrics.java | 7 +-
.../rest/messages/JobVertexBackPressureInfo.java | 45 ++-
.../job/SubtaskExecutionAttemptDetailsInfo.java | 105 +++---
.../taskmanager/TaskManagerDetailsInfo.java | 7 +-
.../rest/messages/taskmanager/TaskManagerInfo.java | 32 +-
.../threadinfo/JobVertexThreadInfoTracker.java | 24 +-
.../executiongraph/ArchivedExecutionGraphTest.java | 356 +++++----------------
.../ArchivedExecutionGraphTestUtils.java | 191 +++++++++++
...ecutionVertexWithSpeculativeExecutionTest.java} | 185 +++--------
.../messages/webmonitor/JobDetailsTest.java | 46 ++-
.../metrics/dump/MetricDumpSerializerTest.java | 140 ++++----
.../runtime/metrics/dump/QueryScopeInfoTest.java | 182 +++++------
.../resourcemanager/ResourceManagerTest.java | 96 ++++++
.../utils/TestingResourceManagerGateway.java | 2 +-
.../job/JobVertexBackPressureHandlerTest.java | 279 +++++++++++++---
.../SubtaskCurrentAttemptDetailsHandlerTest.java | 3 +-
.../SubtaskExecutionAttemptDetailsHandlerTest.java | 3 +-
.../AggregatingSubtasksMetricsHandlerTest.java | 6 +-
.../job/metrics/JobVertexMetricsHandlerTest.java | 4 +-
.../job/metrics/SubtaskMetricsHandlerTest.java | 4 +-
.../messages/ClusterOverviewWithVersionTest.java | 2 +-
.../handler/legacy/metrics/MetricFetcherTest.java | 5 +-
.../handler/legacy/metrics/MetricStoreTest.java | 111 +++++--
.../taskmanager/TaskManagerDetailsHandlerTest.java | 21 +-
.../messages/AggregatedTaskDetailsInfoTest.java | 3 +-
.../messages/JobVertexBackPressureInfoTest.java | 24 +-
.../rest/messages/JobVertexDetailsInfoTest.java | 24 +-
.../SubtaskExecutionAttemptDetailsInfoTest.java | 3 +-
.../messages/taskmanager/TaskManagerInfoTest.java | 3 +-
.../runtime/webmonitor/TestingRestfulGateway.java | 2 +-
58 files changed, 1879 insertions(+), 1002 deletions(-)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedSpeculativeExecutionVertex.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTestUtils.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/{SpeculativeExecutionVertexTest.java
=> ArchivedExecutionVertexWithSpeculativeExecutionTest.java} (52%)
