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%)