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 64557da [hotfix][runtime] Add missing generics in RecordWriterBuilder for avoiding unchecked warning add eea0561 [hotfix] Fix checkstyle violations in LeaderElectionService add 4813a23 [FLINK-14298] Replace LeaderContender#getAddress with #getDescription add 394d930 [hotfix] Add FutureUtils.completedVoidFuture add c2f6866 [hotfix] Use simulated self-type idiom in TestingRestful/DispatcherGateway.Builder add eb1bf7d [hotfix] Fix checkstyle violations in RpcEndpoint add aa09f11 [hotfix] Add JobGraphStoreFactory add 707975e [hotfix] Add TriFunctionWithException add 467736a [hotfix] Let AbstractMetricGroupTest extend TestLogger add cda6dc0 [FLINK-14307] Extract JobGraphWriter from JobGraphStore No new revisions were added by this update. Summary of changes: ...Function.java => TriFunctionWithException.java} | 33 ++++++++- .../webmonitor/LeaderRetrievalHandlerTest.java | 2 +- .../webmonitor/handlers/JarDeleteHandlerTest.java | 2 +- .../flink/runtime/concurrent/FutureUtils.java | 11 +++ .../nonha/embedded/EmbeddedLeaderService.java | 3 +- .../flink/runtime/jobmanager/JobGraphStore.java | 25 +------ .../JobGraphStoreFactory.java} | 16 ++--- .../flink/runtime/jobmanager/JobGraphWriter.java} | 45 ++++++------ .../runtime/jobmaster/JobManagerRunnerImpl.java | 10 +-- .../runtime/leaderelection/LeaderContender.java | 17 ++--- .../leaderelection/LeaderElectionService.java | 4 +- .../ZooKeeperLeaderElectionService.java | 16 ++--- .../org/apache/flink/runtime/rpc/RpcEndpoint.java | 1 - .../flink/runtime/util/LeaderConnectionInfo.java | 2 +- .../runtime/webmonitor/WebMonitorEndpoint.java | 2 +- .../nonha/embedded/EmbeddedHaServicesTest.java | 49 +++++-------- .../nonha/embedded/TestingLeaderContender.java | 2 +- .../SingleLeaderElectionServiceTest.java | 23 +++---- .../runtime/leaderelection/LeaderElectionTest.java | 4 +- .../runtime/leaderelection/TestingContender.java | 4 +- .../TestingLeaderElectionService.java | 14 ++-- .../ZooKeeperLeaderElectionTest.java | 13 +++- .../metrics/groups/AbstractMetricGroupTest.java | 3 +- .../runtime/rest/RestServerSSLAuthITCase.java | 2 +- .../runtime/rest/handler/AbstractHandlerTest.java | 2 +- .../handler/job/JobExecutionResultHandlerTest.java | 8 +-- .../job/JobVertexBackPressureHandlerTest.java | 2 +- .../handler/legacy/ExecutionGraphCacheTest.java | 2 +- .../webmonitor/TestingDispatcherGateway.java | 9 ++- .../runtime/webmonitor/TestingRestfulGateway.java | 80 +++++++++++++--------- .../YarnIntraNonHaMasterServicesTest.java | 3 - 31 files changed, 219 insertions(+), 190 deletions(-) copy flink-core/src/main/java/org/apache/flink/util/function/{TriFunction.java => TriFunctionWithException.java} (55%) copy flink-runtime/src/main/java/org/apache/flink/runtime/{state/Keyed.java => jobmanager/JobGraphStoreFactory.java} (73%) copy flink-runtime/src/{test/java/org/apache/flink/runtime/jobmanager/StandaloneJobGraphStoreTest.java => main/java/org/apache/flink/runtime/jobmanager/JobGraphWriter.java} (53%)