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 531d6bf [hotfix] Extract common logic of getting CheckpointingMode as
StreamingJobGraphGenerator#getCheckpointingMode
add 53755ec [FLINK-16303][rest] Enable retrieval of custom JobManager log
files
No new revisions were added by this update.
Summary of changes:
docs/_includes/generated/rest_v1_dispatcher.html | 64 +++++++++-
.../runtime/webmonitor/WebFrontendITCase.java | 13 ++
.../src/test/resources/rest_api_v1.snapshot | 39 +++++-
.../runtime/resourcemanager/ResourceManager.java | 2 +-
.../resourcemanager/ResourceManagerGateway.java | 2 +-
.../cluster/AbstractJobManagerFileHandler.java | 83 +++++++++++++
.../cluster/JobManagerCustomLogHandler.java | 60 ++++++++++
.../handler/cluster/JobManagerLogFileHandler.java | 55 +++++++++
.../handler/cluster/JobManagerLogListHandler.java | 79 +++++++++++++
.../rest/handler/legacy/ConstantTextHandler.java | 57 ---------
.../legacy/files/StaticFileServerHandler.java | 9 +-
.../AbstractTaskManagerFileHandler.java | 91 +-------------
.../taskmanager/TaskManagerCustomLogHandler.java | 2 +-
.../taskmanager/TaskManagerLogListHandler.java | 4 +-
.../runtime/rest/handler/util/HandlerUtils.java | 80 +++++++++++++
.../LogFileNamePathParameter.java | 6 +-
.../rest/messages/{taskmanager => }/LogInfo.java | 13 +-
.../messages/{taskmanager => }/LogListInfo.java | 3 +-
.../FileMessageParameters.java} | 22 ++--
.../JobManagerCustomLogHeaders.java} | 27 +++--
.../cluster/JobManagerLogFileHeader.java} | 27 +++--
.../JobManagerLogListHeaders.java} | 24 ++--
.../cluster/JobManagerStdoutFileHeader.java} | 26 ++--
.../taskmanager/TaskManagerCustomLogHeaders.java | 1 +
.../TaskManagerFileMessageParameters.java | 1 +
.../taskmanager/TaskManagerLogsHeaders.java | 1 +
.../flink/runtime/taskexecutor/TaskExecutor.java | 2 +-
.../runtime/taskexecutor/TaskExecutorGateway.java | 2 +-
.../runtime/webmonitor/WebMonitorEndpoint.java | 70 ++++++-----
.../flink/runtime/webmonitor/WebMonitorUtils.java | 17 ++-
.../utils/TestingResourceManagerGateway.java | 2 +-
.../cluster/JobManagerLogListHandlerTest.java | 131 +++++++++++++++++++++
.../taskmanager/TaskManagerLogListHandlerTest.java | 4 +-
.../rest/messages/taskmanager/LogListInfoTest.java | 2 +
.../taskexecutor/TestingTaskExecutorGateway.java | 2 +-
35 files changed, 765 insertions(+), 258 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/AbstractJobManagerFileHandler.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/JobManagerCustomLogHandler.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/JobManagerLogFileHandler.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/JobManagerLogListHandler.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ConstantTextHandler.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager
=> }/LogFileNamePathParameter.java (85%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager
=> }/LogInfo.java (88%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager
=> }/LogListInfo.java (94%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager/TaskManagerFileMessageParameters.java
=> cluster/FileMessageParameters.java} (63%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager/TaskManagerCustomLogHeaders.java
=> cluster/JobManagerCustomLogHeaders.java} (62%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/rest/{handler/legacy/files/LogFileHandlerSpecification.java
=> messages/cluster/JobManagerLogFileHeader.java} (54%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager/TaskManagerLogsHeaders.java
=> cluster/JobManagerLogListHeaders.java} (65%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/rest/{handler/legacy/files/StdoutFileHandlerSpecification.java
=> messages/cluster/JobManagerStdoutFileHeader.java} (56%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/cluster/JobManagerLogListHandlerTest.java
