Skip to content

Commit 25a6736

Browse files
committed
Increase the default timeout to 120s
1 parent 6e37c30 commit 25a6736

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,12 +49,12 @@ object RpcUtils {
4949
/** Returns the default Spark timeout to use for RPC ask operations. */
5050
def askTimeout(conf: SparkConf): FiniteDuration = {
5151
conf.getTimeAsSeconds("spark.rpc.askTimeout",
52-
conf.get("spark.network.timeout", "30s")) seconds
52+
conf.get("spark.network.timeout", "120s")) seconds
5353
}
5454

5555
/** Returns the default Spark timeout to use for RPC remote endpoint lookup. */
5656
def lookupTimeout(conf: SparkConf): FiniteDuration = {
5757
conf.getTimeAsSeconds("spark.rpc.lookupTimeout",
58-
conf.get("spark.network.timeout", "30s")) seconds
58+
conf.get("spark.network.timeout", "120s")) seconds
5959
}
6060
}

docs/configuration.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1000,14 +1000,14 @@ Apart from these, the following properties are also available, and may be useful
10001000
</tr>
10011001
<tr>
10021002
<td><code>spark.rpc.askTimeout</code></td>
1003-
<td>30s</td>
1003+
<td>120s</td>
10041004
<td>
10051005
Duration for an RPC ask operation to wait before timing out.
10061006
</td>
10071007
</tr>
10081008
<tr>
10091009
<td><code>spark.rpc.lookupTimeout</code></td>
1010-
<td>30s</td>
1010+
<td>120s</td>
10111011
Duration for an RPC remote endpoint lookup operation to wait before timing out.
10121012
<td>
10131013
</td>

0 commit comments

Comments
 (0)