Add a comment
Project: http://git-wip-us.apache.org/repos/asf/reef/repo Commit: http://git-wip-us.apache.org/repos/asf/reef/commit/a21aa3c0 Tree: http://git-wip-us.apache.org/repos/asf/reef/tree/a21aa3c0 Diff: http://git-wip-us.apache.org/repos/asf/reef/diff/a21aa3c0 Branch: refs/heads/master Commit: a21aa3c0317b933387ca73e721e313e23bbb25c6 Parents: 3df7267 Author: taegeonum <[email protected]> Authored: Fri Mar 24 09:45:40 2017 +0900 Committer: taegeonum <[email protected]> Committed: Fri Mar 24 09:45:40 2017 +0900 ---------------------------------------------------------------------- .../java/org/apache/reef/wake/remote/RemoteConfiguration.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/reef/blob/a21aa3c0/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/RemoteConfiguration.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/RemoteConfiguration.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/RemoteConfiguration.java index a3efe69..4e3dfa2 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/RemoteConfiguration.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/RemoteConfiguration.java @@ -39,6 +39,10 @@ public final class RemoteConfiguration { /** * The timeout of connection retrying. + * To prevent retrying connections from being rejected by the remote stages, + * the retrying_timeout * number_of_retries should be less than the remote_executor_shutdown_timeout. + * If not, the remote stage can shutdown the connection retries before it is established, + * and can drop a message that should be sent to the remote. */ public static final long REMOTE_CONNECTION_RETRY_TIMEOUT = WakeParameters.REMOTE_EXECUTOR_SHUTDOWN_TIMEOUT / (REMOTE_CONNECTION_NUMBER_OF_RETRIES + 1);
