[
https://issues.apache.org/jira/browse/FLINK-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15898701#comment-15898701
]
ASF GitHub Bot commented on FLINK-5918:
---------------------------------------
Github user barcahead commented on a diff in the pull request:
https://github.com/apache/flink/pull/3416#discussion_r104584562
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala ---
@@ -720,5 +722,55 @@ object AkkaUtils {
if (sslEnabled) "akka.ssl.tcp" else "akka.tcp"
}
+ /**
+ * Retries a function if it fails because of a
[[java.net.BindException]].
+ *
+ * @param fn The function to retry
+ * @param stopCond Flag to signal termination
+ * @param maxSleepBetweenRetries Max random sleep time between retries
+ * @tparam T Return type of the the function to retry
+ * @return Return value of the the function to retry
+ */
+ @tailrec
+ def retryOnBindException[T](
+ fn: => T,
+ stopCond: => Boolean,
+ maxSleepBetweenRetries : Long = 0 )
+ : scala.util.Try[T] = {
--- End diff --
@tillrohrmann the style is fixed :-)
> port range support for config taskmanager.rpc.port
> --------------------------------------------------
>
> Key: FLINK-5918
> URL: https://issues.apache.org/jira/browse/FLINK-5918
> Project: Flink
> Issue Type: Improvement
> Components: Core
> Affects Versions: 1.3.0
> Reporter: Yelei Feng
> Assignee: Yelei Feng
> Fix For: 1.3.0
>
>
> we should support to set port range for config {{taskmanager.rpc.port}}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
