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