You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/02/18 08:04:02 UTC
[flink] 03/05: [hotfix][runtime] Small docs/comments cleanups in
RPC code.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2da3bc31fbbc52ef08f6bae8188d366e3094599f
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Feb 5 20:08:41 2020 +0100
[hotfix][runtime] Small docs/comments cleanups in RPC code.
---
.../src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java | 2 --
.../org/apache/flink/runtime/rpc/messages/RemoteRpcInvocation.java | 6 +++---
2 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java
index bc0da64..f67984d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java
@@ -166,8 +166,6 @@ public abstract class RpcEndpoint implements RpcGateway, AutoCloseableAsync {
/**
* Triggers start of the rpc endpoint. This tells the underlying rpc server that the rpc endpoint is ready
* to process remote procedure calls.
- *
- * @throws Exception indicating that something went wrong while starting the RPC endpoint
*/
public final void start() {
rpcServer.start();
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteRpcInvocation.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteRpcInvocation.java
index 486816d..db7a204 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteRpcInvocation.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteRpcInvocation.java
@@ -29,8 +29,8 @@ import java.io.Serializable;
/**
* Remote rpc invocation message which is used when the actor communication is remote and, thus, the
* message has to be serialized.
- * <p>
- * In order to fail fast and report an appropriate error message to the user, the method name, the
+ *
+ * <p>In order to fail fast and report an appropriate error message to the user, the method name, the
* parameter types and the arguments are eagerly serialized. In case the invocation call
* contains a non-serializable object, then an {@link IOException} is thrown.
*/
@@ -138,7 +138,7 @@ public class RemoteRpcInvocation implements RpcInvocation, Serializable {
// -------------------------------------------------------------------
/**
- * Wrapper class for the method invocation information
+ * Wrapper class for the method invocation information.
*/
private static final class MethodInvocation implements Serializable {
private static final long serialVersionUID = 9187962608946082519L;