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/10/11 05:52:29 UTC
[flink] branch master updated (64557da -> cda6dc0)

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%)