Skip to content

Commit 171cea8

Browse files
CodingCatrxin
authored andcommitted
SPARK-1523: improve the readability of code in AkkaUtil
Actually it is separated from #85 as suggested by @rxin compare https://github.com/apache/spark/blob/master/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala#L122 and https://github.com/apache/spark/blob/master/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala#L117 the first one use get and then toLong, the second one getLong....better to make them consistent very very small fix........ Author: CodingCat <zhunansjtu@gmail.com> Closes #434 from CodingCat/SPARK-1523 and squashes the following commits: 0e86f3f [CodingCat] improve the readability of code in AkkaUtil (cherry picked from commit 3c7a9ba) Signed-off-by: Reynold Xin <rxin@apache.org>
1 parent 1a30429 commit 171cea8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/util/AkkaUtils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ private[spark] object AkkaUtils extends Logging {
119119

120120
/** Returns the default Spark timeout to use for Akka remote actor lookup. */
121121
def lookupTimeout(conf: SparkConf): FiniteDuration = {
122-
Duration.create(conf.get("spark.akka.lookupTimeout", "30").toLong, "seconds")
122+
Duration.create(conf.getLong("spark.akka.lookupTimeout", 30), "seconds")
123123
}
124124

125125
/** Returns the configured max frame size for Akka messages in bytes. */

0 commit comments

Comments
 (0)