This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch FLINK-11843
in repository https://gitbox.apache.org/repos/asf/flink.git.
at 7d36f6a [FLINK-11843] Move DispatcherService into
AbstractDispatcherLeaderProcess
This branch includes the following new commits:
new ec2d970 [FLINK-14205] Return DuplicateJobSubmissionException if
submitted job is a duplicate
new 666b633 [hotfix] Remove Exception from
ZooKeeperUtils#createLeaderRetrievalService
new bec55ed [FLINK-XXXX] Add FutureUtils#forward utility
new 6e9db64 [FLINK-XXXX] Encapsulate Dispatcher services in
DispatcherServices
new d344d6b [FLINK-XXXX] Introduce JobManagerRunner interface
new 4530fd5 [FLINK-XXXX] Port MiniDispatcherTest to use new
TestingJobManagerRunnerFactoryNG
new 22f159eb [FLINK-XXXX] Port DispatcherHATest to use
TetingJobManagerRunnerFactoryNG
new d6b0915 [FLINK-XXXX] Port ZooKeeperHaDispatcherTest to use
TestingJobManagerRunnerFactoryNG
new 1a564e5 [FLINK-XXXX] Replace TestingJobManagerRunnerFactory with
TestingJobManagerRunnerFactoryNG in DispatcherTest
new 87ae286 [FLINK-XXXX] Port DispatcherResourceCleanupTest to use
TestingJobManagerRunnerFactoryNG
new 58c0abc [FLINK-XXXX] Remove TestingJobManagerRunnerFactory and rename
TestingJobManagerRunnerFactoryNG
new 6700861 [FLINK-XXXX] Add PermanentlyFencedRpcEndpoint
new fb04121 [FLINK-XXXX] Upgrade InMemoryJobGraphStore to
TestingJobGraphStore
new 311d2cb [FLINK-XXXX] Extend
DispatcherResourceManagerComponentFactory.create to take ioExecutor
new 5c60f33 [FLINK-11843] Add DispatcherRunner
new abcd50d Simplify component structure
new 463d0dc Simplify component factories
new 24c8cdd [FLINK-XXXX] Add DispatcherRunnerImplTest
new fc8a6ec [FLINK-XXXX] Finish unit test for FLINK-11665
new e3f49ef [FLINK-XXXX] Add test case for FLINK-11843
new 30d196a [FLINK-XXXX] Move Akka specific parsing out of
LeaderConnectionInfo
new 168c2e5 [hotfix] Remove Scala Promise from LeaderRetrievalUtils
new ed86e96 [FLINK-XXXX] Change LeaderElectionService#confirmLeadership
to accept leader address
new a1be7c5 [hotfix] Fix checkstyle violations in LeaderElectionService
new da2a666 [FLINK-XXXX] Replace LeaderContender#getAddress with
#getDescription
new a0f9363 [FLINK-11843] Add DispatcherRunnerImplNG with
DispatcherLeaderProcess abstraction
new f5f0806 [hotfix] Add FutureUtils.completedVoidFuture
new 38c0c0e [hotfix] Use simulated self-type idiom in
TestingRestful/DispatcherGateway.Builder
new d587712 [FLINK-11843] Add DispatcherLeaderProcessImpl
new 8a0281b [hotfix] Fix checkstyle violations in RpcEndpoint
new 10be004 [FLINK-XXXX] Add JobGraphStoreFactory
new 637b0e7 [FLINK-11843] Add factory implementations
new b48815b [FLINK-11843] Rename DispatcherFactoryServices into
PartialDispatcherFactoryServices
new 14ba51a [FLINK-11843] Allow to pass JobGraphStore into Dispatcher via
DispatcherServices
new ee9b7df [FLINK-11843] Remove JobGraphListener from Dispatcher
new eb4c55c [FLINK-11843] Allow passing collection of recovered jobs to
Dispatcher
new 1cedd69 [FLINK-XXXX] Extract JobGraphWriter from JobGraphStore
new e835218 [FLINK-11843] Remove job recovery from Dispatcher
new c84de9e [FLINK-11843] Restrict Dispatcher to only use JobGraphWriter
instead of JobGraphStore
new 9dd1e0b [FLINK-XXXX] Add TriFunctionWithException
new ad0d835 [FLINK-11843] Make Dispatcher a PermanentlyFencedRpcEndpoint
new f361b52 [hotfix] Enable DispatcherRunnerImplNG
new c77cf01 [FLINK-11665] Port ZooKeeperDispatcherRunnerImplTest to use
DispatcherRunnerImplNG
new aea096e [FLINK-11843] Enable DispatcherRunnerImplTest for
DispatcherRunnerImplNG
new a75ea9d [hotfix] Improve DispatcherRunnerImplTest to use
TestingRpcServiceResource
new 7892d64 [hotfix] Remove Dispatcher leader retrieval service from
DispatcherRunnerImplTest.testJobRecoveryUnderLeaderChange
new c2a020f [hotfix] Improve ZooKeeperDispatcherRunnerImplTest to use
TestingRpcServiceResource
new 86bb552 [FLINK-11843] Don't close JobManagerMetricGroup in Dispatcher
new d7f18e0 [hotfix] Let AbstractMetricGroupTest extend TestLogger
new 27b91a3 [FLINK-XXXX] Support unregistering metrics from
AbstractMetricGroup
new 207c29c [FLINK-XXXX] Allow MetricNames.NUM_RUNNING_JOBS to be
registered multiple times
new ca03a4f [FLINK-11843] Port MiniDispatcherTest to not do leader
election for the MiniDispatcher
new 065708a [FLINK-11843] Create AbstractDispatcherLeaderProcess
new e0dcfe3 [FLINK-11843] Add proper per-job mode support
new 1e7f19e [hotfix] Remove explicit JobGraphWriter from Dispatcher
constructor
new 8d92fcc [FLINK-11843] Port DispatcherTest
new ae9134a [FLINK-11843] Remove DispatcherTest#testLeaderElection
new 8a388c9 [FLINK-11843] Port
DispatcherTest#testJobSuspensionWhenDispatcherLosesLeadership
new 149fba4 [FLINK-11843] Port
DispatcherTest#testFatalErrorAfterJobRecoveryFailure
new 47da25f [FLINK-11843] Port
DispatcherTest#testFatalErrorAfterJobIdRecoveryFailure
new f0e7649 [FLINK-11843] Port
DispatcherTest#testJobSubmissionErrorAfterJobRecovery
new cf1bb18 [FLINK-11843] Port DispatcherTest#testJobRecovery
new 55f4e13 [FLINK-11843] Clean up DispatcherTest
new d0c10fe [FLINK-11843] Port DispatcherResourceCleanupTest
new 2e63b26 [hotfix] Pass in DispatcherServices into TestingDispatcher
new c69ee95 [FLINK-11843] Pass in explicit JobGraphWriter in
DispatcherTests
new 6067096 [FLINK-11843] Remove
DispatcherHATest#testFailingRecoveryIsFatalError
new 71adbf9 [FLINK-11843] Port
DispatcherHATest#testRevokeLeadershipTerminatesJobManagerRunners
new 8150b73 [FLINK-11843] Remove
DispatcherHATest#testJobRecoveryWhenChangingLeadership
new 11a1fab [FLINK-11843] Remove
DispatcherHATest#testGrantingRevokingLeadership
new 67501eb [FLINK-11843] Remove
ZooKeeperHADispatcherTest#testStandbyDispatcherJobExecution
new 7153ed9 [FLINK-11843] Remove
ZooKeeperHADispatcherTest#testJobGraphRelease
new 59097e2 [FLINK-11843] Delete
ZooKeeperHADispatcherTest#testStandbyDispatcherJobRecovery
new 8e6be09 [FLINK-11843] Delete DispatcherHATest
new 8a553ba [FLINK-11843] Ignore duplicate job submission due to false
positive onAddedJobGraph callbacks
new e2fb247 [FLINK-11843] Properly remove job graphs which have been
removed from the JobGraphStore
new cfe2124 [FLINK-11843] Forward shut down future from Dispatcher
through to the DispatcherRunnerImplNG
new 7d36f6a [FLINK-11843] Move DispatcherService into
AbstractDispatcherLeaderProcess
The 78 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.
