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
