This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e287f22140d [FLINK-38775][release] Generate reference data for state
migration tests based on release-2.2.0 (#27317)
add 2c9bbebc231 [FLINK-38760][runtime] Add REST APIs for application query
and cancellation
No new revisions were added by this update.
Summary of changes:
.../src/test/resources/rest_api_v1.snapshot | 162 +++++++++++++++
.../runtime/application/ArchivedApplication.java | 118 +++++++++++
.../flink/runtime/dispatcher/Dispatcher.java | 106 ++++++++++
...java => FlinkApplicationNotFoundException.java} | 12 +-
...ionTerminatedWithoutCancellationException.java} | 33 +--
.../messages/webmonitor/ApplicationDetails.java | 200 ++++++++++++++++++
.../webmonitor/ApplicationDetailsInfo.java | 228 +++++++++++++++++++++
...tails.java => MultipleApplicationsDetails.java} | 32 ++-
.../ApplicationCancellationHandler.java} | 88 +++-----
.../ApplicationDetailsHandler.java} | 34 +--
.../ApplicationsOverviewHandler.java} | 21 +-
...rs.java => ApplicationCancellationHeaders.java} | 27 +--
... ApplicationCancellationMessageParameters.java} | 22 +-
...ameter.java => ApplicationIDPathParameter.java} | 18 +-
...ters.java => ApplicationMessageParameters.java} | 9 +-
...aders.java => ApplicationsOverviewHeaders.java} | 24 +--
.../ApplicationDetailsHeaders.java} | 31 +--
...ializer.java => ApplicationIDDeserializer.java} | 16 +-
...erializer.java => ApplicationIDSerializer.java} | 14 +-
.../NonLeaderRetrievalRestfulGateway.java | 21 ++
.../flink/runtime/webmonitor/RestfulGateway.java | 36 ++++
.../runtime/webmonitor/WebMonitorEndpoint.java | 38 ++++
.../runtime/messages/GenericMessageTester.java | 10 +
.../runtime/messages/WebMonitorMessagesTest.java | 110 ++++++++++
.../webmonitor/ApplicationDetailsInfoTest.java | 104 ++++++++++
...etailsTest.java => ApplicationDetailsTest.java} | 89 ++++----
.../MultipleApplicationsDetailsTest.java | 74 +++++++
.../ApplicationCancellationHandlerTest.java} | 75 +++----
.../application/ApplicationDetailsHandlerTest.java | 102 +++++++++
.../ApplicationsOverviewHandlerTest.java} | 69 +++----
.../webmonitor/TestingDispatcherGateway.java | 14 ++
.../runtime/webmonitor/TestingRestfulGateway.java | 85 ++++++++
32 files changed, 1708 insertions(+), 314 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/application/ArchivedApplication.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/messages/{FlinkJobNotFoundException.java
=> FlinkApplicationNotFoundException.java} (72%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/messages/{FlinkJobTerminatedWithoutCancellationException.java
=> FlinkApplicationTerminatedWithoutCancellationException.java} (53%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/ApplicationDetails.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/ApplicationDetailsInfo.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/{MultipleJobsDetails.java
=> MultipleApplicationsDetails.java} (67%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/{job/JobCancellationHandler.java
=> application/ApplicationCancellationHandler.java} (53%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/{cluster/JobManagerEnvironmentHandler.java
=> application/ApplicationDetailsHandler.java} (61%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/{cluster/JobManagerThreadDumpHandler.java
=> application/ApplicationsOverviewHandler.java} (74%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{JobCancellationHeaders.java
=> ApplicationCancellationHeaders.java} (66%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{JobVertexMessageParameters.java
=> ApplicationCancellationMessageParameters.java} (62%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{JobIDPathParameter.java
=> ApplicationIDPathParameter.java} (69%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{JobMessageParameters.java
=> ApplicationMessageParameters.java} (77%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{JobsOverviewHeaders.java
=> ApplicationsOverviewHeaders.java} (68%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{taskmanager/TaskManagerDetailsHeaders.java
=> application/ApplicationDetailsHeaders.java} (60%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/{JobIDDeserializer.java
=> ApplicationIDDeserializer.java} (74%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/{JobIDSerializer.java
=> ApplicationIDSerializer.java} (78%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/messages/webmonitor/ApplicationDetailsInfoTest.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/messages/webmonitor/{JobDetailsTest.java
=> ApplicationDetailsTest.java} (54%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/messages/webmonitor/MultipleApplicationsDetailsTest.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/{job/JobCancellationHandlerTest.java
=> application/ApplicationCancellationHandlerTest.java} (59%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/application/ApplicationDetailsHandlerTest.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/{job/JobsOverviewHandlerTest.java
=> application/ApplicationsOverviewHandlerTest.java} (58%)
