Skip to content

Commit

Permalink
Merge pull request #7 from rf972/master
Browse files Browse the repository at this point in the history
Merge latest fixes.
  • Loading branch information
rfoley-fw authored Aug 9, 2021
2 parents 47840f7 + e4b5876 commit 99797c9
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 9 deletions.
2 changes: 1 addition & 1 deletion benchmark/tpch/tpch-spark
5 changes: 2 additions & 3 deletions spark/docker/start-master.sh
Original file line number Diff line number Diff line change
Expand Up @@ -20,12 +20,11 @@ fi
if [ $RUNNING_MODE = "interactive" ]; then
DOCKER_IT="-i -t"
fi

# --cpuset-cpus="9-12" \
DOCKER_RUN="docker run ${DOCKER_IT} --rm \
-p 4040:4040 -p 6066:6066 -p 7077:7077 -p 8080:8080 -p 5005:5005 -p 18080:18080 \
--expose 7001 --expose 7002 --expose 7003 --expose 7004 --expose 7005 --expose 7077 --expose 6066 \
--name sparkmaster \
--cpuset-cpus="9-12" \
--network dike-net \
-e MASTER=spark://sparkmaster:7077 \
-e SPARK_CONF_DIR=/conf \
Expand Down Expand Up @@ -58,7 +57,7 @@ if [ $RUNNING_MODE = "interactive" ]; then
else
eval "${DOCKER_RUN}" &
while [ ! -f "${ROOT_DIR}/volume/status/SPARK_MASTER_STATE" ]; do
sleep 1
sleep 1
done

cat "${ROOT_DIR}/volume/status/SPARK_MASTER_STATE"
Expand Down
7 changes: 3 additions & 4 deletions spark/docker/start-worker.sh
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,10 @@ fi
if [ $RUNNING_MODE = "interactive" ]; then
DOCKER_IT="-i -t"
fi

# --cpuset-cpus="16-19" \
DOCKER_RUN="docker run ${DOCKER_IT} --rm -p 8081:8081 \
--expose 7012 --expose 7013 --expose 7014 --expose 7015 --expose 8881 \
--name sparkworker \
--cpuset-cpus="16-19" \
--network dike-net \
-e SPARK_CONF_DIR=/conf \
-e SPARK_WORKER_CORES=2 \
Expand All @@ -46,13 +45,13 @@ DOCKER_RUN="docker run ${DOCKER_IT} --rm -p 8081:8081 \
-u ${USER_ID} \
spark-run-${USER_NAME} ${CMD}"


if [ $RUNNING_MODE = "interactive" ]; then
eval "${DOCKER_RUN}"
else
eval "${DOCKER_RUN}" &
while [ ! -f "${ROOT_DIR}/volume/status/SPARK_WORKER_STATE" ]; do
sleep 1
sleep 1
done

cat "${ROOT_DIR}/volume/status/SPARK_WORKER_STATE"
Expand Down
2 changes: 1 addition & 1 deletion spark/spark
Submodule spark updated 3248 files

0 comments on commit 99797c9

Please sign in to comment.