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 c763c35 [FLINK-11691] Introduce Classloader in the methods of
StateBackendFactory and ConfigurableStateBackend
new ad55d89 [hotfix] Use lambda for heartbeat timeout handler in
ResourceManager
new 4eabeb9 [hotfix] Null resourceManagerAddress when suspending JobMaster
new d3b1d18 [hotfix] Fix checkstyle violation in JobMaster
new c58a784 [hotfix] Fix checkstyle violations in
ExecutionGraphSuspendTest
new f3758f3 [hotfix] Remove unused methods from TaskManagerGateway
new b9cd88a [hotfix][tests] Remove mocking from ExecutionGraphSuspendTest
new 7d41825 [hotfix] Fix checkstyle violation in ExecutionGraph
new 6fa35ea [hotfix] Fix checkstyle violations in JobStatus
new a54f8c8 [hotfix] Fix checkstyle violations in
ArchivedExecutionGraphTest
new c9e392b [FLINK-11537] Make ExecutionGraph#suspend terminate
ExecutionGraph atomically
new db98eab [hotfix][tests] Remove mocking from
ExecutionGraphSchedulingTest
new ce49a90 [FLINK-11678] Change RestfulGateway#requestJob return type to
CompletableFuture<ArchivedExecutionGraph>
new 397c9c6 [FLINK-11678] Let ExecutionGraphCache store only
ArchivedExecutionGraphs
The 13 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:
.../flink/client/cli/CliFrontendListTest.java | 4 +-
.../flink/runtime/executiongraph/Execution.java | 104 +++++++++------
.../runtime/executiongraph/ExecutionGraph.java | 77 +++++------
.../runtime/executiongraph/ExecutionJobVertex.java | 19 ++-
.../runtime/executiongraph/ExecutionVertex.java | 4 +
.../apache/flink/runtime/jobgraph/JobStatus.java | 33 +++--
.../jobmanager/slots/ActorTaskManagerGateway.java | 37 ------
.../jobmanager/slots/TaskManagerGateway.java | 44 -------
.../apache/flink/runtime/jobmaster/JobMaster.java | 3 +-
.../runtime/jobmaster/RpcTaskManagerGateway.java | 33 -----
.../runtime/resourcemanager/ResourceManager.java | 19 ++-
.../rest/handler/legacy/ExecutionGraphCache.java | 57 +++------
.../flink/runtime/webmonitor/RestfulGateway.java | 10 +-
.../executiongraph/ArchivedExecutionGraphTest.java | 8 +-
...ncurrentFailoverStrategyExecutionGraphTest.java | 6 +-
.../ExecutionGraphCoLocationRestartTest.java | 2 +-
.../ExecutionGraphDeploymentTest.java | 6 +-
.../executiongraph/ExecutionGraphRestartTest.java | 10 +-
.../ExecutionGraphSchedulingTest.java | 59 ++++-----
.../executiongraph/ExecutionGraphSuspendTest.java | 103 ++++-----------
.../executiongraph/ExecutionGraphTestUtils.java | 4 +-
.../runtime/executiongraph/ExecutionTest.java | 6 +-
.../executiongraph/ExecutionVertexCancelTest.java | 4 +-
.../ExecutionVertexInputConstraintTest.java | 2 +-
.../runtime/executiongraph/FailoverRegionTest.java | 14 +-
.../executiongraph/GlobalModVersionTest.java | 4 +-
.../InteractionsCountingTaskManagerGateway.java | 63 +++++++++
.../utils/SimpleAckingTaskManagerGateway.java | 37 ------
.../flink/runtime/jobmaster/JobMasterTest.java | 141 ++++++++++-----------
.../handler/legacy/ExecutionGraphCacheTest.java | 104 +--------------
.../taskexecutor/TestingTaskExecutorGateway.java | 17 ++-
.../TestingTaskExecutorGatewayBuilder.java | 20 ++-
.../webmonitor/TestingDispatcherGateway.java | 5 +-
.../runtime/webmonitor/TestingRestfulGateway.java | 14 +-
34 files changed, 428 insertions(+), 645 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/InteractionsCountingTaskManagerGateway.java
