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 8d9e02c [FLINK-23088] Add flink-rpc-core module
add b5d6057 [FLINK-23089] Add flink-rpc-akka-module
No new revisions were added by this update.
Summary of changes:
.../flink-rpc-akka}/pom.xml | 313 +++------------------
.../akka/ActorSystemScheduledExecutorAdapter.java | 0
.../runtime/concurrent/akka/AkkaFutureUtils.java | 0
.../flink/runtime/rpc/akka/AkkaBasedEndpoint.java | 0
.../flink/runtime/rpc/akka/AkkaBootstrapTools.java | 1 -
.../runtime/rpc/akka/AkkaInvocationHandler.java | 0
.../flink/runtime/rpc/akka/AkkaRpcActor.java | 0
.../runtime/rpc/akka/AkkaRpcSerializedValue.java | 0
.../flink/runtime/rpc/akka/AkkaRpcService.java | 1 -
.../rpc/akka/AkkaRpcServiceConfiguration.java | 0
.../runtime/rpc/akka/AkkaRpcServiceUtils.java | 1 -
.../flink/runtime/rpc/akka/AkkaRpcSystem.java | 1 -
.../flink/runtime/rpc/akka/ControlMessages.java | 0
.../rpc/akka/FencedAkkaInvocationHandler.java | 0
.../flink/runtime/rpc/akka/FencedAkkaRpcActor.java | 0
.../flink/runtime/rpc/akka/SupervisorActor.java | 0
.../akka/exceptions/AkkaHandshakeException.java | 0
.../rpc/akka/exceptions/AkkaRpcException.java | 0
.../exceptions/AkkaRpcInvalidStateException.java | 0
.../akka/exceptions/AkkaRpcRuntimeException.java | 0
.../exceptions/AkkaUnknownMessageException.java | 0
.../src/main/resources/META-INF/NOTICE | 2 +-
.../resources/META-INF/licenses/LICENSE.base64 | 0
.../resources/META-INF/licenses/LICENSE.jsr166y | 0
.../main/resources/META-INF/licenses/LICENSE.jzlib | 0
.../resources/META-INF/licenses/LICENSE.webbit | 0
.../org.apache.flink.runtime.rpc.RpcSystem | 2 +-
.../main/scala/akka/actor/RobustActorSystem.scala | 0
.../akka/dispatch/PriorityThreadFactory.scala | 0
.../akka/dispatch/PriorityThreadsDispatcher.scala | 0
.../PriorityThreadsDispatcherPrerequisites.scala | 0
.../apache/flink/runtime/rpc}/akka/AkkaUtils.scala | 5 +-
.../rpc}/akka/CustomSSLEngineProvider.scala | 2 +-
.../rpc}/akka/EscalatingSupervisorStrategy.java | 2 +-
.../runtime/rpc}/akka/RemoteAddressExtension.scala | 2 +-
.../apache/flink/runtime/messages/Acknowledge.java | 73 +++++
.../rpc/DirectlyFailingFatalErrorHandler.java | 0
.../flink/runtime/rpc/TestingRpcService.java | 2 +-
.../runtime/rpc/akka/ActorSystemResource.java | 1 -
.../runtime/rpc/akka/AkkaActorSystemTest.java | 6 +-
.../runtime/rpc/akka/AkkaBootstrapToolsTest.java | 1 -
.../rpc/akka/AkkaRpcActorHandshakeTest.java | 1 -
.../AkkaRpcActorOversizedResponseMessageTest.java | 0
.../flink/runtime/rpc/akka/AkkaRpcActorTest.java | 1 -
.../rpc/akka/AkkaRpcSerializedValueTest.java | 0
.../flink/runtime/rpc/akka/AkkaRpcServiceTest.java | 1 -
.../runtime/rpc/akka/MainThreadValidationTest.java | 1 -
.../runtime/rpc/akka/MessageSerializationTest.java | 0
.../runtime/rpc/akka/RemoteAkkaRpcActorTest.java | 0
.../runtime/rpc/akka/SupervisorActorTest.java | 0
.../runtime/rpc/akka/TimeoutCallStackTest.java | 1 -
.../scala/akka/actor/RobustActorSystemTest.scala | 2 +-
.../flink/runtime/rpc}/akka/AkkaUtilsTest.scala | 7 +-
flink-rpc/pom.xml | 1 +
flink-runtime/pom.xml | 286 +------------------
tools/ci/stage.sh | 1 +
56 files changed, 149 insertions(+), 568 deletions(-)
copy {flink-runtime => flink-rpc/flink-rpc-akka}/pom.xml (60%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/concurrent/akka/ActorSystemScheduledExecutorAdapter.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/concurrent/akka/AkkaFutureUtils.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaBasedEndpoint.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaBootstrapTools.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcSerializedValue.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceConfiguration.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceUtils.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcSystem.java
(98%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/ControlMessages.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/FencedAkkaInvocationHandler.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/FencedAkkaRpcActor.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/SupervisorActor.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/exceptions/AkkaHandshakeException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/exceptions/AkkaRpcException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/exceptions/AkkaRpcInvalidStateException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/exceptions/AkkaRpcRuntimeException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/java/org/apache/flink/runtime/rpc/akka/exceptions/AkkaUnknownMessageException.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/resources/META-INF/NOTICE (99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/resources/META-INF/licenses/LICENSE.base64
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/resources/META-INF/licenses/LICENSE.jsr166y
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/resources/META-INF/licenses/LICENSE.jzlib
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/resources/META-INF/licenses/LICENSE.webbit
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/resources/META-INF/services/org.apache.flink.runtime.rpc.RpcSystem
(94%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/scala/akka/actor/RobustActorSystem.scala
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/scala/akka/dispatch/PriorityThreadFactory.scala
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/scala/akka/dispatch/PriorityThreadsDispatcher.scala
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/main/scala/akka/dispatch/PriorityThreadsDispatcherPrerequisites.scala
(100%)
rename {flink-runtime/src/main/scala/org/apache/flink/runtime =>
flink-rpc/flink-rpc-akka/src/main/scala/org/apache/flink/runtime/rpc}/akka/AkkaUtils.scala
(99%)
rename {flink-runtime/src/main/scala/org/apache/flink/runtime =>
flink-rpc/flink-rpc-akka/src/main/scala/org/apache/flink/runtime/rpc}/akka/CustomSSLEngineProvider.scala
(97%)
rename {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-rpc/flink-rpc-akka/src/main/scala/org/apache/flink/runtime/rpc}/akka/EscalatingSupervisorStrategy.java
(97%)
rename {flink-runtime/src/main/scala/org/apache/flink/runtime =>
flink-rpc/flink-rpc-akka/src/main/scala/org/apache/flink/runtime/rpc}/akka/RemoteAddressExtension.scala
(97%)
create mode 100644
flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/messages/Acknowledge.java
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/DirectlyFailingFatalErrorHandler.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/TestingRpcService.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/ActorSystemResource.java
(97%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaActorSystemTest.java
(95%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaBootstrapToolsTest.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorHandshakeTest.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorOversizedResponseMessageTest.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcSerializedValueTest.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/MainThreadValidationTest.java
(98%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/MessageSerializationTest.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/RemoteAkkaRpcActorTest.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/SupervisorActorTest.java
(100%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/java/org/apache/flink/runtime/rpc/akka/TimeoutCallStackTest.java
(99%)
rename {flink-runtime =>
flink-rpc/flink-rpc-akka}/src/test/scala/akka/actor/RobustActorSystemTest.scala
(98%)
rename {flink-runtime/src/test/scala/org/apache/flink/runtime =>
flink-rpc/flink-rpc-akka/src/test/scala/org/apache/flink/runtime/rpc}/akka/AkkaUtilsTest.scala
(97%)
