Skip to content

Commit 89a9cbf

Browse files
committed
+ Added sleep to prevent some issues
1 parent 230131c commit 89a9cbf

File tree

1 file changed

+14
-11
lines changed

1 file changed

+14
-11
lines changed

config/spark-cmd.sh

Lines changed: 14 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -8,20 +8,23 @@ $HADOOP_HOME/sbin/start-yarn.sh
88
sleep 5
99

1010
if [[ $1 = "start" ]]; then
11-
if [[ $2 = "master-node" ]]; then
12-
/sbin/spark-3.1.1-bin-without-hadoop/sbin/start-master.sh
11+
if [[ $2 = "master-node" ]]; then
12+
/sbin/spark-3.1.1-bin-without-hadoop/sbin/start-master.sh
13+
sleep infinity
14+
exit
15+
fi
16+
17+
# Sleeps to prevent connection issues with master
18+
sleep 5
19+
/sbin/spark-3.1.1-bin-without-hadoop/sbin/start-worker.sh master-node:7077
1320
sleep infinity
1421
exit
15-
fi
16-
/sbin/spark-3.1.1-bin-without-hadoop/sbin/start-worker.sh master-node:7077
17-
sleep infinity
18-
exit
1922
fi
2023

2124
if [[ $1 = "stop" ]]; then
22-
if [[ $2 = "master-node" ]]; then
23-
/sbin/spark-3.1.1-bin-without-hadoop/sbin/stop-master.sh
24-
exit
25-
fi
26-
/sbin/spark-3.1.1-bin-without-hadoop/sbin/stop-worker.sh
25+
if [[ $2 = "master-node" ]]; then
26+
/sbin/spark-3.1.1-bin-without-hadoop/sbin/stop-master.sh
27+
exit
28+
fi
29+
/sbin/spark-3.1.1-bin-without-hadoop/sbin/stop-worker.sh
2730
fi

0 commit comments

Comments
 (0)