(args, hdfs_cluster, s)
| 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: |
| 80 | return |
| 81 | for hdfs_instance in hdfs_cluster.cluster: |
| 82 | #print hdfs_instance.to_string() |
| 83 | cmd = hdfs_instance.to_cmd(args.docker, hdfs_cluster.master_ip, ' '.join(hdfs_cluster.slave_ip)) |
| 84 | print cmd |
| 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: |