Skip to content
Permalink
Browse files
[hotfix][akka][docs] Replace LocalRpcInvocation with RpcInvocation
This closes #8033.
  • Loading branch information
chummyhe89 authored and zentol committed May 17, 2022
1 parent 8f9ca89 commit 3719369bb5488c65ac01342307bdbb95c7289d63
Showing 2 changed files with 4 additions and 5 deletions.
@@ -66,7 +66,7 @@

/**
* Invocation handler to be used with an {@link AkkaRpcActor}. The invocation handler wraps the rpc
* in a {@link LocalRpcInvocation} message and then sends it to the {@link AkkaRpcActor} where it is
* in an {@link RpcInvocation} message and then sends it to the {@link AkkaRpcActor} where it is
* executed.
*/
class AkkaInvocationHandler implements InvocationHandler, AkkaBasedEndpoint, RpcServer {
@@ -29,7 +29,6 @@
import org.apache.flink.runtime.rpc.exceptions.RpcConnectionException;
import org.apache.flink.runtime.rpc.messages.CallAsync;
import org.apache.flink.runtime.rpc.messages.HandshakeSuccessMessage;
import org.apache.flink.runtime.rpc.messages.LocalRpcInvocation;
import org.apache.flink.runtime.rpc.messages.RemoteHandshakeMessage;
import org.apache.flink.runtime.rpc.messages.RpcInvocation;
import org.apache.flink.runtime.rpc.messages.RunAsync;
@@ -65,11 +64,11 @@
import static org.apache.flink.util.Preconditions.checkNotNull;

/**
* Akka rpc actor which receives {@link LocalRpcInvocation}, {@link RunAsync} and {@link CallAsync}
* Akka rpc actor which receives {@link RpcInvocation}, {@link RunAsync} and {@link CallAsync}
* {@link ControlMessages} messages.
*
* <p>The {@link LocalRpcInvocation} designates a rpc and is dispatched to the given {@link
* RpcEndpoint} instance.
* <p>The {@link RpcInvocation} designates a rpc and is dispatched to the given {@link RpcEndpoint}
* instance.
*
* <p>The {@link RunAsync} and {@link CallAsync} messages contain executable code which is executed
* in the context of the actor thread.

0 comments on commit 3719369

Please sign in to comment.