Optimize AWS EMR spark settings (spark-config-cheatsheet)
Project description
# Spark-optimizer
[![Build Status](https://api.travis-ci.org/delijati/spark-optimizer.svg?branch=master)](https://travis-ci.org/delijati/spark-optimizer)
Optimize spark settings (for cluster aka yarn run)
Original source: http://c2fo.io/c2fo/spark/aws/emr/2016/07/06/apache-spark-config-cheatsheet/
## Usage
Install:
$ virtualenv env
$ env/bin/pip install spark-optimizer
Dev install:
$ virtualenv env
$ env/bin/pip install -e .
Generate settings for `c4.4xlarge` with `4` nodes:
$ env/bin/spark-optimizer c4.4xlarge 4
{'spark.default.parallelism': '108',
'spark.driver.cores': '2',
'spark.driver.maxResultSize': '3481m',
'spark.driver.memory': '3481m',
'spark.driver.memoryOverhead': '614m',
'spark.executor.cores': '2',
'spark.executor.instances': '27',
'spark.executor.memory': '3481m',
'spark.executor.memoryOverhead': '614m'}
Update instance info:
$ env/bin/python spark_optimizer/emr_update.py
# CHANGES
0.1.3 (2019-03-08)
------------------
- add emr cost to yaml
- export load yaml file
- make ``memory_overhead_coefficient`` editable
0.1.2 (2019-02-20)
------------------
- unpin the versions
- rename cli from _ to -
0.1.1 (2018-09-12)
------------------
- fix email
0.1.0 (2018-09-12)
- initial release
[![Build Status](https://api.travis-ci.org/delijati/spark-optimizer.svg?branch=master)](https://travis-ci.org/delijati/spark-optimizer)
Optimize spark settings (for cluster aka yarn run)
Original source: http://c2fo.io/c2fo/spark/aws/emr/2016/07/06/apache-spark-config-cheatsheet/
## Usage
Install:
$ virtualenv env
$ env/bin/pip install spark-optimizer
Dev install:
$ virtualenv env
$ env/bin/pip install -e .
Generate settings for `c4.4xlarge` with `4` nodes:
$ env/bin/spark-optimizer c4.4xlarge 4
{'spark.default.parallelism': '108',
'spark.driver.cores': '2',
'spark.driver.maxResultSize': '3481m',
'spark.driver.memory': '3481m',
'spark.driver.memoryOverhead': '614m',
'spark.executor.cores': '2',
'spark.executor.instances': '27',
'spark.executor.memory': '3481m',
'spark.executor.memoryOverhead': '614m'}
Update instance info:
$ env/bin/python spark_optimizer/emr_update.py
# CHANGES
0.1.3 (2019-03-08)
------------------
- add emr cost to yaml
- export load yaml file
- make ``memory_overhead_coefficient`` editable
0.1.2 (2019-02-20)
------------------
- unpin the versions
- rename cli from _ to -
0.1.1 (2018-09-12)
------------------
- fix email
0.1.0 (2018-09-12)
- initial release
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
spark_optimizer-0.1.3.tar.gz
(10.5 kB
view details)
File details
Details for the file spark_optimizer-0.1.3.tar.gz
.
File metadata
- Download URL: spark_optimizer-0.1.3.tar.gz
- Upload date:
- Size: 10.5 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.13.0 pkginfo/1.5.0.1 requests/2.20.1 setuptools/40.6.2 requests-toolbelt/0.8.0 tqdm/4.31.1 CPython/3.6.6
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | bdacc0639c9ac219e03697597c5d5aaa40f6cac0bac23a0207821aaf3b64c2f0 |
|
MD5 | 83426c8a46f8c422e08d27981204f872 |
|
BLAKE2b-256 | 706f969c1283caea9b1a01973383aa181d57c308c9ccdf3f1481bf5347c9452a |