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 2020/10/20 21:07:59 UTC
[flink] branch release-1.10 updated (072c78e -> 9fe6c78)

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 072c78e  [FLINK-13553] Ignore KvStateServerHandlerTest because it is unstable
     add 58643ea  [hotfix] Add CoreMatchers.willNotComplete to assert that a future times out
     add 91829d3  [hotfix] Let DispatcherResourceManagerComponent accept AutoCloseableAsync instead of WebMonitorEndpoint
     add 1843cbe  [hotfix] Introduce ResourceManagerService to make DispatcherResourceManagerComponent easier to test
     add b11918e  [hotfix] Correct TestingDispatcherGatewayService closeAsync behavior
     add 26344b2  [FLINK-19022][rpc] Log if RpcEndpoint failed its termination
     add e0b4de2  [FLINK-19022] Let TaskExecutor, Dispatcher, RM fail fatally if onStart throws a Throwable
     add 2c6bef2  [FLINK-19022] Fail fatally if DispatcherGatewayService terminates unexpectedly in AbstractDispatcherLeaderProcess
     add 4ffc99c  [FLINK-19022] Fail DispatcherResourceManagerComponent fatally if ResourceManager terminates unexpectedly
     add 9fe6c78  [FLINK-19022] Fail TaskManagerRunner fatally if TaskExecutor terminates unexpectedly

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/flink/util/CoreMatchers.java   | 49 +++++++++++
 .../flink/runtime/dispatcher/Dispatcher.java       |  4 +-
 .../runner/AbstractDispatcherLeaderProcess.java    | 28 ++++++-
 .../runner/DefaultDispatcherGatewayService.java    |  5 ++
 ...tDispatcherResourceManagerComponentFactory.java |  5 +-
 .../component/DefaultResourceManagerService.java   | 56 +++++++++++++
 .../DispatcherResourceManagerComponent.java        | 40 +++++++--
 .../runtime/resourcemanager/ResourceManager.java   |  4 +-
 .../flink/runtime/rpc/akka/AkkaRpcActor.java       |  2 +
 .../flink/runtime/taskexecutor/TaskExecutor.java   |  4 +-
 .../TaskExecutorToServiceAdapter.java}             | 35 +++++---
 .../runtime/taskexecutor/TaskManagerRunner.java    | 71 ++++++++++++++--
 .../runner/SessionDispatcherLeaderProcessTest.java | 46 ++++++++++-
 .../runner/TestingDispatcherGatewayService.java    | 45 +++++-----
 .../dispatcher/runner/TestingDispatcherRunner.java | 78 ++++++++++++++++++
 .../DispatcherResourceManagerComponentTest.java    | 95 ++++++++++++++++++++++
 .../component/TestingResourceManagerService.java   | 93 +++++++++++++++++++++
 .../taskexecutor/TaskManagerRunnerTest.java        | 64 ++++++++++++++-
 .../taskexecutor/TestingTaskExecutorService.java   | 92 +++++++++++++++++++++
 .../JobManagerHAProcessFailureRecoveryITCase.java  |  2 +-
 20 files changed, 760 insertions(+), 58 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DefaultResourceManagerService.java
 copy flink-runtime/src/{test/java/org/apache/flink/runtime/taskexecutor/NoOpPartitionProducerStateChecker.java => main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorToServiceAdapter.java} (52%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/TestingDispatcherRunner.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponentTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/component/TestingResourceManagerService.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorService.java