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;