You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/09/25 14:06:40 UTC
[flink] branch FLINK-11843 created (now 7d36f6a)
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.