This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0436cee1c7c [FLINK-27427][rpc] Remove timeouts from RpcUtils#terminate*
add c93e7d8a38c [FLINK-27426][rpc][tests] Remove unnecessary future
timeouts
add e5134217057 [FLINK-27426][rpc] Migrate RPC system internals to Duration
No new revisions were added by this update.
Summary of changes:
.../runtime/rpc/akka/AkkaInvocationHandler.java | 26 +++++++++++-----------
.../flink/runtime/rpc/akka/AkkaRpcService.java | 5 ++---
.../rpc/akka/AkkaRpcServiceConfiguration.java | 11 ++++-----
.../rpc/akka/FencedAkkaInvocationHandler.java | 11 ++++-----
.../rpc/akka/AkkaRpcActorHandshakeTest.java | 9 ++------
.../flink/runtime/rpc/akka/AkkaRpcActorTest.java | 26 ++++++++++------------
.../flink/runtime/rpc/akka/AkkaRpcServiceTest.java | 5 +----
.../rpc/akka/ContextClassLoadingSettingTest.java | 9 +++-----
.../runtime/rpc/FencedMainThreadExecutable.java | 5 ++---
.../flink/runtime/rpc/FencedRpcEndpoint.java | 5 +++--
.../flink/runtime/rpc/MainThreadExecutable.java | 5 ++---
.../org/apache/flink/runtime/rpc/RpcEndpoint.java | 12 +++++-----
.../runtime/metrics/dump/MetricQueryService.java | 3 ++-
.../active/ActiveResourceManager.java | 12 +++++-----
.../flink/runtime/taskexecutor/TaskExecutor.java | 6 +++--
.../taskexecutor/TaskManagerConfiguration.java | 12 +++++-----
.../runtime/dispatcher/TestingDispatcher.java | 7 ++++--
.../apache/flink/runtime/rpc/AsyncCallsTest.java | 21 ++++++++---------
.../flink/runtime/rpc/FencedRpcEndpointTest.java | 3 ++-
.../apache/flink/runtime/rpc/RpcEndpointTest.java | 14 +++++-------
.../runtime/taskexecutor/TaskExecutorTest.java | 3 ++-
.../taskexecutor/slot/ThreadSafeTaskSlotTable.java | 3 ++-
22 files changed, 103 insertions(+), 110 deletions(-)
