You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by xt...@apache.org on 2022/06/13 07:57:14 UTC

[flink] branch master updated (aa693b5076f -> 41ac1ba1367)

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

xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from aa693b5076f [FLINK-27903][runtime] Make pipelinedRegionSchedulingStrategyTest also support testing for hybrid resultPartitionType.
     add 41ac1ba1367 [FLINK-27737][rpc] Remove legacy support for unfenced executor in FencedRpcEndpoint

No new revisions were added by this update.

Summary of changes:
 .../KubernetesResourceManagerDriver.java           |   2 -
 .../flink/runtime/rpc/akka/AkkaRpcService.java     |   3 -
 .../rpc/akka/FencedAkkaInvocationHandler.java      |  54 +----
 .../flink/runtime/rpc/akka/FencedAkkaRpcActor.java |  14 +-
 .../runtime/rpc/FencedMainThreadExecutable.java    |  47 -----
 .../flink/runtime/rpc/FencedRpcEndpoint.java       | 145 +------------
 .../runtime/rpc/PermanentlyFencedRpcEndpoint.java  |  51 -----
 .../runtime/rpc/messages/UnfencedMessage.java      |  49 -----
 .../flink/runtime/dispatcher/Dispatcher.java       |   4 +-
 .../apache/flink/runtime/jobmaster/JobMaster.java  |   4 +-
 .../runtime/dispatcher/TestingDispatcher.java      |  25 +--
 .../apache/flink/runtime/rpc/AsyncCallsTest.java   | 160 +--------------
 .../flink/runtime/rpc/FencedRpcEndpointTest.java   | 227 ---------------------
 .../flink/yarn/YarnResourceManagerDriver.java      |   2 -
 14 files changed, 19 insertions(+), 768 deletions(-)
 delete mode 100644 flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/FencedMainThreadExecutable.java
 delete mode 100644 flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/PermanentlyFencedRpcEndpoint.java
 delete mode 100644 flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/messages/UnfencedMessage.java