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 a8580ca [FLINK-10912][rocksdb] Configurable RocksDBStateBackend
options
new b7c013c [hotfix] Allow leader assignment to
TestingLeaderElectionService if it has not been started
new ba089aa [FLINK-11718][rpc] Add onStart method to RpcEndpoint
new ce71fb5 [hotfix] Factor logic out of AkkaRpcActor#handleRpcInvocation
to reduce size of method
new 579f5e0 [FLINK-11718] Add onStart to Dispatcher
new af69289 [FLINK-11718] Remove start override from JobMaster
new 6b9b242 [FLINK-11718] Add onStart method to ResourceManager
new 1023694 [FLINK-11718] Add onStart method to TaskExecutor
new 09568bd [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
