This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0fe9815 [FLINK-10912][rocksdb] Configurable RocksDBStateBackend
options
new 0291460 [hotfix] Allow leader assignment to
TestingLeaderElectionService if it has not been started
new 98baea3 [FLINK-11718][rpc] Add onStart method to RpcEndpoint
new fe7b11a [hotfix] Factor logic out of AkkaRpcActor#handleRpcInvocation
to reduce size of method
new f6cbd8b [FLINK-11718] Add onStart to Dispatcher
new 68c2aaf [FLINK-11718] Remove start override from JobMaster
new 008701d [FLINK-11718] Add onStart method to ResourceManager
new 51d428a [FLINK-11718] Add onStart method to TaskExecutor
new 8e66e9b [FLINK-11718] Make RpcEndpoint#start method final to prevent
changing its behaviour
The 8 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/runtime/dispatcher/Dispatcher.java | 86 ++++++----
.../apache/flink/runtime/jobmaster/JobMaster.java | 7 +-
.../runtime/resourcemanager/ResourceManager.java | 52 ++++--
.../org/apache/flink/runtime/rpc/RpcEndpoint.java | 18 +-
.../flink/runtime/rpc/akka/AkkaRpcActor.java | 187 ++++++++++++++-------
.../flink/runtime/taskexecutor/TaskExecutor.java | 85 +++++++---
.../flink/runtime/dispatcher/DispatcherHATest.java | 3 +
.../flink/runtime/dispatcher/DispatcherTest.java | 4 +-
.../runtime/dispatcher/TestingDispatcher.java | 20 +++
.../TestingLeaderElectionService.java | 48 ++++--
.../flink/runtime/rpc/akka/AkkaRpcActorTest.java | 68 ++++++++
.../runtime/taskexecutor/TaskExecutorTest.java | 9 +-
.../runtime/taskexecutor/TestingTaskExecutor.java | 75 +++++++++
13 files changed, 501 insertions(+), 161 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutor.java
