diff options
| author | kalpit <shahkalpit84@gmail.com> | 2013-03-06 18:06:32 -0800 |
|---|---|---|
| committer | kalpit <shahkalpit84@gmail.com> | 2013-03-26 17:49:30 -0700 |
| commit | f08db010d3ba4eff132f5c06a087b0c7c2e58576 (patch) | |
| tree | 6b08dfbbcb05594b7ce2d712d33e105bf9bd214c /bin/start-slaves.sh | |
| parent | f0164e5047f3a023768cdf0515a7a7d1c75ef7c3 (diff) | |
| download | spark-f08db010d3ba4eff132f5c06a087b0c7c2e58576.tar.gz spark-f08db010d3ba4eff132f5c06a087b0c7c2e58576.tar.bz2 spark-f08db010d3ba4eff132f5c06a087b0c7c2e58576.zip | |
added SPARK_WORKER_INSTANCES : allows spawning multiple worker instances/processes on every slave machine
Diffstat (limited to 'bin/start-slaves.sh')
| -rwxr-xr-x | bin/start-slaves.sh | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/bin/start-slaves.sh b/bin/start-slaves.sh index 390247ca4a..4e05224190 100755 --- a/bin/start-slaves.sh +++ b/bin/start-slaves.sh @@ -21,4 +21,13 @@ fi echo "Master IP: $SPARK_MASTER_IP" # Launch the slaves -exec "$bin/slaves.sh" cd "$SPARK_HOME" \; "$bin/start-slave.sh" spark://$SPARK_MASTER_IP:$SPARK_MASTER_PORT +if [ "$SPARK_WORKER_INSTANCES" = "" ]; then + exec "$bin/slaves.sh" cd "$SPARK_HOME" \; "$bin/start-slave.sh" 1 spark://$SPARK_MASTER_IP:$SPARK_MASTER_PORT +else + if [ "$SPARK_WORKER_WEBUI_PORT" = "" ]; then + SPARK_WORKER_WEBUI_PORT=8081 + fi + for ((i=0; i<$SPARK_WORKER_INSTANCES; i++)); do + "$bin/slaves.sh" cd "$SPARK_HOME" \; "$bin/start-slave.sh" $(( $i + 1 )) spark://$SPARK_MASTER_IP:$SPARK_MASTER_PORT --webui-port $(( $SPARK_WORKER_WEBUI_PORT + $i )) + done +fi |