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 f6a7100 [FLINK-10602] Use metric's ActorSystem in MetricFetcher
new 9219dc9 [hotfix][runtime] Log stacktrace if checkpoint cannot be
ack'ed.
new eb51a5f [hotfix][tests] Remove invalid logger from log4j config.
new d850e79 [FLINK-10309][rest] Before shutting down cluster, wait for
asynchronous operations.
new e96cdf1 [FLINK-10309][tests] Replace wait-notify with
CountDownLatches.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runtime/entrypoint/ClusterEntrypoint.java | 4 +-
.../DispatcherResourceManagerComponent.java | 107 +++++-----
.../apache/flink/runtime/jobmaster/JobMaster.java | 2 +-
.../flink/runtime/rest/RestServerEndpoint.java | 17 +-
.../rest/{ => handler}/AbstractHandler.java | 35 +++-
.../runtime/rest/handler/AbstractRestHandler.java | 9 +-
.../rest/handler/InFlightRequestTracker.java | 66 +++++++
.../AbstractAsynchronousOperationHandlers.java | 93 +--------
.../handler/async/CompletedOperationCache.java | 216 +++++++++++++++++++++
.../async/UnknownOperationKeyException.java} | 15 +-
.../handler/job/AsynchronousJobOperationKey.java | 2 +-
.../AbstractTaskManagerFileHandler.java | 2 +-
.../runtime/rest/handler/util/HandlerUtils.java | 38 ++--
.../FileArchivedExecutionGraphStoreTest.java | 15 +-
.../runtime/rest/RestServerEndpointITCase.java | 216 +++++++++++++++------
.../rest/{ => handler}/AbstractHandlerTest.java | 6 +-
.../rest/handler/InFlightRequestTrackerTest.java | 81 ++++++++
.../AbstractAsynchronousOperationHandlersTest.java | 26 +++
.../handler/async/CompletedOperationCacheTest.java | 80 ++++++++
.../apache/flink/runtime/util/ManualTicker.java} | 28 +--
.../recovery/ProcessFailureCancelingITCase.java | 3 +-
.../src/test/resources/log4j-test.properties | 2 +-
22 files changed, 790 insertions(+), 273 deletions(-)
rename flink-runtime/src/main/java/org/apache/flink/runtime/rest/{ =>
handler}/AbstractHandler.java (87%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/InFlightRequestTracker.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCache.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{messages/FlinkJobNotFoundException.java
=> rest/handler/async/UnknownOperationKeyException.java} (66%)
rename flink-runtime/src/test/java/org/apache/flink/runtime/rest/{ =>
handler}/AbstractHandlerTest.java (96%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/InFlightRequestTrackerTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCacheTest.java
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/util/ResettableIterator.java
=> test/java/org/apache/flink/runtime/util/ManualTicker.java} (67%)
