[flink] branch master updated (a2b669f -> 505a808)

[ga...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gary pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from a2b669f  [hotfix][doc] Document union list metadata gotcha
     add c125c04  [FLINK-16302][rest] Enable retrieval of custom TaskManager log files
     add 505a808  [FLINK-16302][rest] Add tests for (un)marshalling LogListInfo

No new revisions were added by this update.

Summary of changes:
 docs/_includes/generated/rest_v1_dispatcher.html   |  66 ++++++++++++
 .../src/test/resources/rest_api_v1.snapshot        |  37 +++++++
 .../runtime/resourcemanager/ResourceManager.java   |  34 +++++-
 .../resourcemanager/ResourceManagerGateway.java    |  23 +++-
 .../AbstractTaskManagerFileHandler.java            |  29 ++++--
 .../taskmanager/AbstractTaskManagerHandler.java    |  14 ++-
 ...ndler.java => TaskManagerCustomLogHandler.java} |  24 +++--
 .../taskmanager/TaskManagerLogFileHandler.java     |   5 +-
 .../taskmanager/TaskManagerLogListHandler.java     |  88 ++++++++++++++++
 .../taskmanager/TaskManagerStdoutFileHandler.java  |   5 +-
 ...arameter.java => LogFileNamePathParameter.java} |  20 ++--
 .../{TaskManagersInfo.java => LogInfo.java}        |  36 ++++---
 .../{TaskManagersInfo.java => LogListInfo.java}    |  33 +++---
 ...aders.java => TaskManagerCustomLogHeaders.java} |  18 ++--
 .../TaskManagerFileMessageParameters.java}         |  17 +--
 ...ilsHeaders.java => TaskManagerLogsHeaders.java} |  40 +++----
 .../flink/runtime/taskexecutor/TaskExecutor.java   |  82 ++++++++++-----
 .../runtime/taskexecutor/TaskExecutorGateway.java  |  20 +++-
 .../taskexecutor/TaskManagerConfiguration.java     |  15 +++
 .../runtime/webmonitor/WebMonitorEndpoint.java     |  23 ++++
 .../utils/TestingResourceManagerGateway.java       |  45 +++++++-
 .../AbstractTaskManagerFileHandlerTest.java        |   8 +-
 .../taskmanager/TaskManagerLogListHandlerTest.java | 116 +++++++++++++++++++++
 .../rest/messages/taskmanager/LogListInfoTest.java |  30 +++---
 .../runtime/taskexecutor/TaskExecutorTest.java     |   2 +-
 .../taskexecutor/TestingTaskExecutorGateway.java   |  14 ++-
 26 files changed, 682 insertions(+), 162 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/{TaskManagerStdoutFileHandler.java => TaskManagerCustomLogHandler.java} (71%)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerLogListHandler.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/{TaskManagerIdPathParameter.java => LogFileNamePathParameter.java} (64%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/{TaskManagersInfo.java => LogInfo.java} (62%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/{TaskManagersInfo.java => LogListInfo.java} (64%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/{TaskManagerLogFileHeaders.java => TaskManagerCustomLogHeaders.java} (72%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{job/metrics/AggregatedJobMetricsParameters.java => taskmanager/TaskManagerFileMessageParameters.java} (66%)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/{TaskManagerDetailsHeaders.java => TaskManagerLogsHeaders.java} (72%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerLogListHandlerTest.java
 copy flink-tests/src/test/java/org/apache/flink/test/util/InfiniteIntegerSource.java => flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/taskmanager/LogListInfoTest.java (57%)