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