(args, zk_cluster, s)
| 67 | return zk_cluster, hdfs_cluster, tera_cluster |
| 68 | |
| 69 | def start_zk(args, zk_cluster, s): |
| 70 | if (args.hdfs or args.tera) and not args.zk: |
| 71 | return |
| 72 | for zk_instance in zk_cluster.cluster: |
| 73 | #print zk_instance.to_string() |
| 74 | cmd = zk_instance.to_cmd(' '.join(zk_cluster.ip_zk), args.docker) |
| 75 | print cmd |
| 76 | s.run_cmd(zk_instance.ip, cmd) |
| 77 | |
| 78 | def start_hdfs(args, hdfs_cluster, s): |
| 79 | if (args.zk or args.tera) and not args.hdfs: |