Skip to content

Commit dbd5f73

Browse files
committed
[SPARK-6980] Changed RpcUtils askRpcTimeout and lookupRpcTimeout scope to private[spark] and improved deprecation warning msg
1 parent 4e89c75 commit dbd5f73

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,21 +47,21 @@ object RpcUtils {
4747
}
4848

4949
/** Returns the default Spark timeout to use for RPC ask operations. */
50-
def askRpcTimeout(conf: SparkConf): RpcTimeout = {
50+
private[spark] def askRpcTimeout(conf: SparkConf): RpcTimeout = {
5151
RpcTimeout(conf, Seq("spark.rpc.askTimeout", "spark.network.timeout"), "120s")
5252
}
5353

54-
@deprecated("use askRpcTimeout instead", "1.5.0")
54+
@deprecated("use askRpcTimeout instead, this method was not intended to be public", "1.5.0")
5555
def askTimeout(conf: SparkConf): FiniteDuration = {
5656
askRpcTimeout(conf).duration
5757
}
5858

5959
/** Returns the default Spark timeout to use for RPC remote endpoint lookup. */
60-
def lookupRpcTimeout(conf: SparkConf): RpcTimeout = {
60+
private[spark] def lookupRpcTimeout(conf: SparkConf): RpcTimeout = {
6161
RpcTimeout(conf, Seq("spark.rpc.lookupTimeout", "spark.network.timeout"), "120s")
6262
}
6363

64-
@deprecated("use lookupRpcTimeout instead", "1.5.0")
64+
@deprecated("use lookupRpcTimeout instead, this method was not intended to be public", "1.5.0")
6565
def lookupTimeout(conf: SparkConf): FiniteDuration = {
6666
lookupRpcTimeout(conf).duration
6767
}

0 commit comments

Comments
 (0)