diff options
Diffstat (limited to 'docs/configuration.md')
-rw-r--r-- | docs/configuration.md | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/docs/configuration.md b/docs/configuration.md index 8a186ee51c..fea259204a 100644 --- a/docs/configuration.md +++ b/docs/configuration.md @@ -31,7 +31,6 @@ which can help detect bugs that only exist when we run in a distributed context. val conf = new SparkConf() .setMaster("local[2]") .setAppName("CountingSheep") - .set("spark.executor.memory", "1g") val sc = new SparkContext(conf) {% endhighlight %} @@ -84,7 +83,7 @@ Running `./bin/spark-submit --help` will show the entire list of these options. each line consists of a key and a value separated by whitespace. For example: spark.master spark://5.6.7.8:7077 - spark.executor.memory 512m + spark.executor.memory 4g spark.eventLog.enabled true spark.serializer org.apache.spark.serializer.KryoSerializer @@ -150,10 +149,9 @@ of the most common options to set are: </tr> <tr> <td><code>spark.executor.memory</code></td> - <td>512m</td> + <td>1g</td> <td> - Amount of memory to use per executor process, in the same format as JVM memory strings - (e.g. <code>512m</code>, <code>2g</code>). + Amount of memory to use per executor process (e.g. <code>2g</code>, <code>8g</code>). </td> </tr> <tr> @@ -886,11 +884,11 @@ Apart from these, the following properties are also available, and may be useful </tr> <tr> <td><code>spark.akka.frameSize</code></td> - <td>10</td> + <td>128</td> <td> - Maximum message size to allow in "control plane" communication (for serialized tasks and task - results), in MB. Increase this if your tasks need to send back large results to the driver - (e.g. using <code>collect()</code> on a large dataset). + Maximum message size to allow in "control plane" communication; generally only applies to map + output size information sent between executors and the driver. Increase this if you are running + jobs with many thousands of map and reduce tasks and see messages about the frame size. </td> </tr> <tr> |