streams-flink/startFlinkCluster.sh at master · alexeyegorov/streams-flink · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
#!/usr/bin/env bash


if [ $# != 1 ]
	then
	echo "An argument is required: start or stop."
	exit -1
fi

username="egorov"
flink_master="ls8ws007"
flink_worker1="ls8ws008"
flink_worker2="ls8ws009"
flink_worker3="ls8ws010"
filename=$2

printf "\n\nUser: $username\nMaster: $flink_master\nWorker1: $flink_worker1\nWorker2: $flink_worker2\nWorker3: $flink_worker3\n\n"


if [[ $1 == "start" ]]; then

    echo "Start master..."
    master_start_cmd="cd flink; ./bin/start-cluster.sh;"
    start_master=`ssh "$username"@"$flink_master".cs.uni-dortmund.de "$master_start_cmd"`

    echo "Wait for master to start..."
    sleep 10

    workerstartcmd="cd flink; ./bin/taskmanager.sh start streaming;"

    echo "Start worker 1..."
    echo `ssh "$username"@"$flink_worker1".cs.uni-dortmund.de "$workerstartcmd"`

    echo "Start worker 2..."
    echo `ssh "$username"@"$flink_worker2".cs.uni-dortmund.de "$workerstartcmd"`

    echo "Start worker 3..."
    echo `ssh "$username"@"$flink_worker3".cs.uni-dortmund.de "$workerstartcmd"`
else

    echo "Stop master..."
    master_start_cmd="cd flink; ./bin/stop-cluster.sh;"
    start_master=`ssh "$username"@"$flink_master".cs.uni-dortmund.de "$master_start_cmd"`

    workerstopcmd="cd flink; ./bin/taskmanager.sh stop-all;"

    echo "Stop worker 1..."
    echo `ssh "$username"@"$flink_worker1".cs.uni-dortmund.de "$workerstopcmd"`

    echo "Stop worker 2..."
    echo `ssh "$username"@"$flink_worker2".cs.uni-dortmund.de "$workerstopcmd"`

    echo "Stop worker 3..."
    echo `ssh "$username"@"$flink_worker3".cs.uni-dortmund.de "$workerstopcmd"`
fi