-
Notifications
You must be signed in to change notification settings - Fork 2
/
Copy pathrun_experiment.py
41 lines (40 loc) · 2.33 KB
/
run_experiment.py
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
import itertools
import os
import sys
hadoop = ['rel/release-2.10.1', 'rel/release-3.1.4', 'rel/release-3.3.0', 'rel/release-3.2.1', 'rel/release-2.9.2']
hadoop.reverse()
tags_dict = {
'hbase' :['rel/1.4.13', 'rel/1.6.0', 'rel/2.2.6', 'rel/2.3.3','master'],
'hive' :['rel/release-1.2.2', 'rel/release-2.1.0', 'rel/release-2.1.1', 'rel/release-2.2.0', 'rel/release-2.3.0', 'rel/release-2.3.1', 'rel/release-2.3.2', 'rel/release-2.3.3', 'rel/release-2.3.4', 'rel/release-2.3.5', 'rel/release-2.3.6', 'rel/release-2.3.7', 'rel/release-3.0.0', 'rel/release-3.1.0', 'rel/release-3.1.1', 'rel/release-3.1.2'],
'hadoop' : ['rel/release-2.6.4', 'rel/release-2.7.2', 'rel/release-2.8.0', 'rel/release-2.9.0', 'rel/release-2.10.0', 'rel/release-3.0.0', 'rel/release-3.1.0', 'rel/release-3.2.0', 'rel/release-3.3.0', '7bc78ab707901a6ba9b3a517f8e30aa08c88fe52'],
'impala': ['refs/tags/2.7.0', 'refs/tags/2.8.0', 'refs/tags/2.9.0', 'refs/tags/2.10.0', 'refs/tags/2.11.0', 'refs/tags/2.12.0', 'refs/tags/3.0.0', 'refs/tags/3.0.1', 'refs/tags/3.1.0', 'refs/tags/3.2.0', 'refs/tags/3.3.0', 'refs/tags/3.4.0', 'master'],
'mesos': ['1.4.3', '1.5.2', '1.7.0', '1.7.3', '1.9.0', '1.10.0', '1.11.0', "master"],
'accumulo': ["1.7.0", "rel/1.10.0","rel/2.0.0","rel/2.0.0-alpha-1","rel/2.0.0-alpha-2","rel/2.0.1","main"]
}
if len(sys.argv) > 2:
key = sys.argv[1]
ty = sys.argv[2]
tags = tags_dict[key]
combinations = list(itertools.combinations(tags,2))
if key == 'hadoop':
combinations.append(['rel/release-3.1.0', 'rel/release-3.1.1'])
for t in combinations:
log_fn = "log/" + key + "_" + ty + t[0].replace("/","-") + "--" + t[1].replace("/","-") + ".log"
cmd = "python3 checker.py --{} --app {} --v1 {} --v2 {} > {}".format(ty, key, t[0], t[1], log_fn)
print(cmd)
os.system(cmd)
else:
for key in tags_dict:
tags = tags_dict[key]
if key == 'impala' or key == 'accumulo':
ty = 'thrift'
else:
ty = 'proto'
combinations = list(itertools.combinations(tags,2))
if key == 'hadoop':
combinations.append(['rel/release-3.1.0', 'rel/release-3.1.1'])
for t in combinations:
log_fn = "log/" + key + "_" + ty + t[0].replace("/","-") + "--" + t[1].replace("/","-") + ".log"
cmd = "python3 checker.py --{} --app {} --v1 {} --v2 {} > {}".format(ty, key, t[0], t[1], log_fn)
print(cmd)
os.system(cmd)