You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/05/01 13:37:11 UTC
[flink] branch master updated (8ab08cc4 -> 4dc1f7e)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8ab08cc4 [hotfix] fix donwload link
add 7c53d71 [hotfix] Add comments to FileType enum values
add 42a4dfd [hotfix] Factor out putTransientBlobStream from requestFileuploadFilePath
add 0294409 [FLINK-14816] Add thread dump feature for taskmanager
add 4dc1f7e [FLINK-14816] Let TaskManagerThreadDumpHandler return JSON response
No new revisions were added by this update.
Summary of changes:
.../src/test/resources/rest_api_v1.snapshot | 37 +++++++
.../src/app/interfaces/task-manager.ts | 9 ++
.../status/task-manager-status.component.ts | 2 +-
.../task-manager/task-manager-routing.module.ts | 8 ++
.../app/pages/task-manager/task-manager.module.ts | 4 +-
.../task-manager-thread-dump.component.html} | 4 +-
.../task-manager-thread-dump.component.less} | 0
.../task-manager-thread-dump.component.ts} | 37 ++++---
.../src/app/services/task-manager.service.ts | 14 ++-
.../runtime/resourcemanager/ResourceManager.java | 14 +++
.../resourcemanager/ResourceManagerGateway.java | 10 ++
...dler.java => TaskManagerThreadDumpHandler.java} | 31 +++---
...ders.java => TaskManagerThreadDumpHeaders.java} | 47 +++++----
.../rest/messages/taskmanager/ThreadDumpInfo.java | 114 +++++++++++++++++++++
.../flink/runtime/taskexecutor/FileType.java | 9 +-
.../flink/runtime/taskexecutor/TaskExecutor.java | 39 +++++--
.../runtime/taskexecutor/TaskExecutorGateway.java | 9 ++
.../org/apache/flink/runtime/util/JvmUtils.java | 34 +++---
.../runtime/webmonitor/WebMonitorEndpoint.java | 10 ++
.../utils/TestingResourceManagerGateway.java | 18 ++++
...nagersInfoTest.java => ThreadDumpInfoTest.java} | 28 +++--
.../taskexecutor/TestingTaskExecutorGateway.java | 12 ++-
.../TestingTaskExecutorGatewayBuilder.java | 11 +-
23 files changed, 408 insertions(+), 93 deletions(-)
copy flink-runtime-web/web-dashboard/src/app/pages/{job-manager/logs/job-manager-logs.component.html => task-manager/thread-dump/task-manager-thread-dump.component.html} (75%)
copy flink-runtime-web/web-dashboard/src/app/pages/{job-manager/stdout/job-manager-stdout.component.less => task-manager/thread-dump/task-manager-thread-dump.component.less} (100%)
copy flink-runtime-web/web-dashboard/src/app/pages/{job-manager/stdout/job-manager-stdout.component.ts => task-manager/thread-dump/task-manager-thread-dump.component.ts} (55%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/{TaskManagersHandler.java => TaskManagerThreadDumpHandler.java} (61%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/{TaskManagerLogsHeaders.java => TaskManagerThreadDumpHeaders.java} (75%)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java
copy flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/AbstractTimeIndexGenerator.java => flink-runtime/src/main/java/org/apache/flink/runtime/util/JvmUtils.java (58%)
copy flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/taskmanager/{TaskManagersInfoTest.java => ThreadDumpInfoTest.java} (51%)