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 d0741d2 [hotfix][rest][tests] Fix Preconditions placeholder
new fdc32cd [FLINK-12322] Remove legacy ActorTaskManagerGateway
new af83758 [hotfix] Remove legacy DummyActorGateway
new 10b2185 [FLINK-12323] Remove legacy ActorGateway based interface
implementations
new a93d6b1 [hotfix] Remove ActorUtils
new b8c9379 [hotfix] Remove ScalaTestingUtils
new 0bfe466 [FLINK-12324] Remove legacy ActorGateway interface
The 6 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:
.../org/apache/flink/runtime/akka/ActorUtils.java | 99 -----------
.../flink/runtime/instance/ActorGateway.java | 107 ------------
.../flink/runtime/instance/AkkaActorGateway.java | 165 ------------------
.../jobmanager/slots/ActorTaskManagerGateway.java | 192 ---------------------
.../ActorGatewayCheckpointResponder.java | 71 --------
.../ActorGatewayGlobalAggregateManager.java | 32 ----
.../ActorGatewayKvStateLocationOracle.java | 63 -------
.../ActorGatewayKvStateRegistryListener.java | 84 ---------
.../ActorGatewayPartitionProducerStateChecker.java | 68 --------
...orGatewayResultPartitionConsumableNotifier.java | 78 ---------
.../ActorGatewayTaskManagerActions.java | 59 -------
.../taskmanager/TaskInputSplitProvider.java | 108 ------------
.../executiongraph/ExecutionGraphRestartTest.java | 20 +--
.../executiongraph/ExecutionGraphTestUtils.java | 30 ----
.../executiongraph/ExecutionVertexCancelTest.java | 8 +-
.../runtime/instance/BaseTestingActorGateway.java | 119 -------------
.../flink/runtime/instance/DummyActorGateway.java | 78 ---------
.../runtime/instance/InstanceManagerTest.java | 60 ++-----
.../flink/runtime/instance/InstanceTest.java | 8 +-
.../flink/runtime/instance/SimpleSlotTest.java | 4 +-
.../taskmanager/ForwardingActorGateway.java | 48 ------
.../taskmanager/TaskInputSplitProviderTest.java | 80 ---------
.../runtime/testingUtils/ScalaTestingUtils.scala | 38 ----
.../flink/runtime/testingUtils/TestingUtils.scala | 15 +-
24 files changed, 31 insertions(+), 1603 deletions(-)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/akka/ActorUtils.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/instance/ActorGateway.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/instance/AkkaActorGateway.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/slots/ActorTaskManagerGateway.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ActorGatewayCheckpointResponder.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ActorGatewayGlobalAggregateManager.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ActorGatewayKvStateLocationOracle.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ActorGatewayKvStateRegistryListener.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ActorGatewayPartitionProducerStateChecker.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ActorGatewayResultPartitionConsumableNotifier.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ActorGatewayTaskManagerActions.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskInputSplitProvider.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/instance/BaseTestingActorGateway.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/instance/DummyActorGateway.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/ForwardingActorGateway.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskInputSplitProviderTest.java
delete mode 100644
flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/ScalaTestingUtils.scala
