You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2021/12/29 01:53:36 UTC
[flink] branch master updated (9f49f10 -> c915ccf)
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9f49f10 [hotfix][jdbc] Fix method name typo in Postgres test
add 72c451c [FLINK-25372] Move ThreadDumpInfo out from taskmanager-specific package
add 91cc35b [FLINK-25372] Add REST API for request JobManager thread-dump
add c915ccf [FLINK-25372] Add thread dump feature for jobmanager on Web UI
No new revisions were added by this update.
Summary of changes:
.../src/test/resources/rest_api_v1.snapshot | 39 ++++++++++++++++-
.../src/app/interfaces/job-manager.ts | 8 ++++
.../job-manager/job-manager-routing.module.ts | 8 ++++
.../app/pages/job-manager/job-manager.component.ts | 3 +-
.../app/pages/job-manager/job-manager.module.ts | 4 +-
.../job-manager-thread-dump.component.html} | 6 +--
.../job-manager-thread-dump.component.less} | 0
.../job-manager-thread-dump.component.ts} | 34 +++++++++------
.../src/app/services/job-manager.service.ts | 10 ++++-
.../flink/runtime/dispatcher/Dispatcher.java | 6 +++
.../runtime/resourcemanager/ResourceManager.java | 2 +-
.../resourcemanager/ResourceManagerGateway.java | 2 +-
...ndler.java => JobManagerThreadDumpHandler.java} | 25 ++++++-----
.../taskmanager/TaskManagerThreadDumpHandler.java | 2 +-
.../messages/{taskmanager => }/ThreadDumpInfo.java | 15 ++++++-
...aders.java => JobManagerThreadDumpHeaders.java} | 50 +++++++++++-----------
.../taskmanager/TaskManagerThreadDumpHeaders.java | 1 +
.../flink/runtime/taskexecutor/TaskExecutor.java | 16 +------
.../runtime/taskexecutor/TaskExecutorGateway.java | 2 +-
.../TaskExecutorGatewayDecoratorBase.java | 2 +-
.../flink/runtime/webmonitor/RestfulGateway.java | 9 ++++
.../runtime/webmonitor/WebMonitorEndpoint.java | 11 +++++
.../utils/TestingResourceManagerGateway.java | 2 +-
.../{taskmanager => }/ThreadDumpInfoTest.java | 4 +-
.../taskexecutor/TestingTaskExecutorGateway.java | 2 +-
.../TestingTaskExecutorGatewayBuilder.java | 2 +-
.../webmonitor/TestingDispatcherGateway.java | 4 ++
.../runtime/webmonitor/TestingRestfulGateway.java | 15 +++++++
28 files changed, 198 insertions(+), 86 deletions(-)
copy flink-runtime-web/web-dashboard/src/app/pages/job-manager/{stdout/job-manager-stdout.component.html => thread-dump/job-manager-thread-dump.component.html} (90%)
copy flink-runtime-web/web-dashboard/src/app/pages/{task-manager/thread-dump/task-manager-thread-dump.component.less => job-manager/thread-dump/job-manager-thread-dump.component.less} (100%)
copy flink-runtime-web/web-dashboard/src/app/pages/job-manager/{stdout/job-manager-stdout.component.ts => thread-dump/job-manager-thread-dump.component.ts} (72%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/{ShutdownHandler.java => JobManagerThreadDumpHandler.java} (68%)
rename flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager => }/ThreadDumpInfo.java (86%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/cluster/{JobManagerLogListHeaders.java => JobManagerThreadDumpHeaders.java} (71%)
rename flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/{taskmanager => }/ThreadDumpInfoTest.java (93%)