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