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 990a7dac90a [FLINK-29403][cep] Streamline SimpleCondition usage
add e9f3ec93aad [FLINK-29487][rpc] RpcService extends AutoCloseableAsync
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java | 2 +-
.../flink/runtime/rpc/akka/AkkaRpcActorHandshakeTest.java | 6 +++---
.../org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java | 2 +-
.../org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java | 4 ++--
.../flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java | 4 ++--
.../flink/runtime/rpc/akka/MainThreadValidationTest.java | 2 +-
.../flink/runtime/rpc/akka/MessageSerializationTest.java | 4 ++--
.../apache/flink/runtime/rpc/akka/RemoteAkkaRpcActorTest.java | 2 +-
.../apache/flink/runtime/rpc/akka/TimeoutCallStackTest.java | 2 +-
.../src/main/java/org/apache/flink/runtime/rpc/RpcService.java | 10 ++--------
.../src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java | 2 +-
.../org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java | 2 +-
.../org/apache/flink/runtime/metrics/MetricRegistryImpl.java | 2 +-
.../java/org/apache/flink/runtime/minicluster/MiniCluster.java | 4 ++--
.../apache/flink/runtime/taskexecutor/TaskManagerRunner.java | 2 +-
.../runtime/dispatcher/DispatcherResourceCleanupTest.java | 2 +-
.../flink/runtime/jobmaster/JobMasterPartitionReleaseTest.java | 2 +-
.../flink/runtime/jobmaster/JobMasterQueryableStateTest.java | 2 +-
.../java/org/apache/flink/runtime/jobmaster/JobMasterTest.java | 2 +-
.../flink/runtime/metrics/dump/MetricQueryServiceTest.java | 2 +-
.../org/apache/flink/runtime/metrics/util/MetricUtilsTest.java | 2 +-
.../runtime/registration/RegisteredRpcConnectionTest.java | 2 +-
.../flink/runtime/registration/RetryingRegistrationTest.java | 2 +-
.../runtime/resourcemanager/TestingResourceManagerService.java | 2 +-
.../test/java/org/apache/flink/runtime/rpc/AsyncCallsTest.java | 2 +-
.../java/org/apache/flink/runtime/rpc/RpcConnectionTest.java | 2 +-
.../java/org/apache/flink/runtime/rpc/RpcEndpointTest.java | 2 +-
.../java/org/apache/flink/runtime/rpc/RpcSSLAuthITCase.java | 4 ++--
.../java/org/apache/flink/runtime/rpc/TestingRpcService.java | 4 ++--
.../apache/flink/runtime/rpc/TestingRpcServiceExtension.java | 2 +-
.../apache/flink/runtime/rpc/TestingRpcServiceResource.java | 2 +-
.../taskexecutor/TaskExecutorOperatorEventHandlingTest.java | 2 +-
.../taskexecutor/TaskExecutorPartitionLifecycleTest.java | 2 +-
.../TaskExecutorToResourceManagerConnectionTest.java | 2 +-
.../taskexecutor/TaskManagerRunnerConfigurationTest.java | 2 +-
.../runtime/taskexecutor/TaskSubmissionTestEnvironment.java | 2 +-
.../coordination/OperatorEventSendingCheckpointITCase.java | 4 ++--
.../org/apache/flink/test/runtime/IPv6HostnamesITCase.java | 2 +-
38 files changed, 48 insertions(+), 54 deletions(-)
