Increase the default timeout to 120s

nemccarthy · Apr 22, 2015 · 25a6736 · 25a6736
1 parent 6e37c30
commit 25a6736
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/RpcUtils.scala b/core/src/main/scala/org/apache/spark/util/RpcUtils.scala
@@ -49,12 +49,12 @@ object RpcUtils {
   /** Returns the default Spark timeout to use for RPC ask operations. */
   def askTimeout(conf: SparkConf): FiniteDuration = {
     conf.getTimeAsSeconds("spark.rpc.askTimeout",
-      conf.get("spark.network.timeout", "30s")) seconds
+      conf.get("spark.network.timeout", "120s")) seconds
   }
 
   /** Returns the default Spark timeout to use for RPC remote endpoint lookup. */
   def lookupTimeout(conf: SparkConf): FiniteDuration = {
     conf.getTimeAsSeconds("spark.rpc.lookupTimeout",
-      conf.get("spark.network.timeout", "30s")) seconds
+      conf.get("spark.network.timeout", "120s")) seconds
   }
 }
diff --git a/docs/configuration.md b/docs/configuration.md
@@ -1000,14 +1000,14 @@ Apart from these, the following properties are also available, and may be useful
 </tr>
 <tr>
   <td><code>spark.rpc.askTimeout</code></td>
-  <td>30s</td>
+  <td>120s</td>
   <td>
     Duration for an RPC ask operation to wait before timing out.
   </td>
 </tr>
 <tr>
   <td><code>spark.rpc.lookupTimeout</code></td>
-  <td>30s</td>
+  <td>120s</td>
     Duration for an RPC remote endpoint lookup operation to wait before timing out.
   <td>
   </td>