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 7cf3783 [hotfix][state/changelog] Rename StateChangelogHandle to
ChangelogStateHandle
add 8d9e02c [FLINK-23088] Add flink-rpc-core module
No new revisions were added by this update.
Summary of changes:
.../flink-rpc-core}/pom.xml | 11 ++++-------
.../flink/runtime/concurrent/ComponentMainThreadExecutor.java | 0
.../flink/runtime/concurrent/ScheduledFutureAdapter.java | 0
.../java/org/apache/flink/runtime/rpc/AddressResolution.java | 0
.../java/org/apache/flink/runtime/rpc/FatalErrorHandler.java | 0
.../apache/flink/runtime/rpc/FencedMainThreadExecutable.java | 0
.../java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java | 0
.../java/org/apache/flink/runtime/rpc/FencedRpcGateway.java | 0
.../org/apache/flink/runtime/rpc/MainThreadExecutable.java | 0
.../org/apache/flink/runtime/rpc/MainThreadValidatorUtil.java | 0
.../flink/runtime/rpc/PermanentlyFencedRpcEndpoint.java | 0
.../main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java | 6 +++---
.../main/java/org/apache/flink/runtime/rpc/RpcGateway.java | 0
.../src/main/java/org/apache/flink/runtime/rpc/RpcServer.java | 0
.../main/java/org/apache/flink/runtime/rpc/RpcService.java | 0
.../java/org/apache/flink/runtime/rpc/RpcServiceUtils.java | 0
.../src/main/java/org/apache/flink/runtime/rpc/RpcSystem.java | 6 ++++--
.../java/org/apache/flink/runtime/rpc/RpcSystemUtils.java | 0
.../main/java/org/apache/flink/runtime/rpc/RpcTimeout.java | 0
.../src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java | 0
.../java/org/apache/flink/runtime/rpc/StartStoppable.java | 0
.../flink/runtime/rpc/exceptions/FencingTokenException.java | 0
.../flink/runtime/rpc/exceptions/HandshakeException.java | 0
.../flink/runtime/rpc/exceptions/RpcConnectionException.java | 0
.../org/apache/flink/runtime/rpc/exceptions/RpcException.java | 0
.../flink/runtime/rpc/exceptions/RpcRuntimeException.java | 0
.../java/org/apache/flink/runtime/rpc/messages/CallAsync.java | 2 +-
.../org/apache/flink/runtime/rpc/messages/FencedMessage.java | 0
.../flink/runtime/rpc/messages/HandshakeSuccessMessage.java | 0
.../apache/flink/runtime/rpc/messages/LocalFencedMessage.java | 0
.../apache/flink/runtime/rpc/messages/LocalRpcInvocation.java | 0
.../flink/runtime/rpc/messages/RemoteFencedMessage.java | 0
.../flink/runtime/rpc/messages/RemoteHandshakeMessage.java | 0
.../flink/runtime/rpc/messages/RemoteRpcInvocation.java | 0
.../org/apache/flink/runtime/rpc/messages/RpcInvocation.java | 4 ++--
.../java/org/apache/flink/runtime/rpc/messages/RunAsync.java | 4 ++--
.../apache/flink/runtime/rpc/messages/UnfencedMessage.java | 0
.../flink/runtime/concurrent/ScheduledFutureAdapterTest.java | 0
{flink-external-resources => flink-rpc}/pom.xml | 7 +++----
flink-runtime/pom.xml | 6 ++++++
.../flink/runtime/metrics/MetricRegistryConfiguration.java | 1 +
.../META-INF/services/org.apache.flink.runtime.rpc.RpcSystem | 2 +-
pom.xml | 1 +
tools/ci/stage.sh | 2 ++
44 files changed, 30 insertions(+), 22 deletions(-)
copy {flink-external-resources/flink-external-resource-gpu =>
flink-rpc/flink-rpc-core}/pom.xml (87%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutor.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/AddressResolution.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/FatalErrorHandler.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/FencedMainThreadExecutable.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/FencedRpcGateway.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/MainThreadExecutable.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/MainThreadValidatorUtil.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/PermanentlyFencedRpcEndpoint.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcGateway.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcServer.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcService.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcServiceUtils.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcSystem.java
(96%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcSystemUtils.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcTimeout.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/StartStoppable.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/exceptions/FencingTokenException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/exceptions/HandshakeException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/exceptions/RpcConnectionException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/exceptions/RpcException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/exceptions/RpcRuntimeException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/CallAsync.java
(95%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/FencedMessage.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/HandshakeSuccessMessage.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/LocalFencedMessage.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/LocalRpcInvocation.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteFencedMessage.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteHandshakeMessage.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteRpcInvocation.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/RpcInvocation.java
(95%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/RunAsync.java
(93%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/main/java/org/apache/flink/runtime/rpc/messages/UnfencedMessage.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-core}/src/test/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapterTest.java
(100%)
copy {flink-external-resources => flink-rpc}/pom.xml (89%)
copy
flink-yarn/src/main/resources/META-INF/services/org.apache.flink.client.deployment.ClusterClientFactory
=>
flink-runtime/src/main/resources/META-INF/services/org.apache.flink.runtime.rpc.RpcSystem
(94%)
