| 85 | s.run_cmd(hdfs_instance.ip, cmd) |
| 86 | |
| 87 | def start_tera(args, tera_cluster, zk_cluster, hdfs_cluster, s): |
| 88 | if (args.zk or args.hdfs) and not args.tera: |
| 89 | return |
| 90 | for tera_instance in tera_cluster.cluster: |
| 91 | #print tera_instance.to_string() |
| 92 | cmd = tera_instance.to_cmd(args.docker, ','.join(zk_cluster.ip_tera), hdfs_cluster.master_ip, ':'.join(hdfs_cluster.slave_ip)) |
| 93 | print cmd |
| 94 | if tera_instance.mode == 'master': |
| 95 | time.sleep(5) |
| 96 | s.run_cmd(tera_instance.ip, cmd) |
| 97 | |
| 98 | def main(): |
| 99 | args = parse_input() |