Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(8)  |  Call(8)  |  Derive(0)  |  Import(0)

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
    def scale_cluster(self, cluster, instances):
        self._setup_instances(cluster, instances)
 
        run.refresh_nodes(remote.get_remote(
            utils.get_namenode(cluster)), "dfsadmin")
        jt = utils.get_jobtracker(cluster)
        if jt:
            run.refresh_nodes(remote.get_remote(jt), "mradmin")

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
    def scale_cluster(self, cluster, instances):
        self._setup_instances(cluster, instances)
 
        run.refresh_nodes(remote.get_remote(
            vu.get_namenode(cluster)), "dfsadmin")
        jt = vu.get_jobtracker(cluster)
        if jt:
            run.refresh_nodes(remote.get_remote(jt), "mradmin")

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v1_2_1/scaling.py   sahara(Download)
                        utils.generate_fqdn_host_names(
                            inst_to_be_deleted))
        run.refresh_nodes(remote.get_remote(jt), "mradmin")
        context.sleep(3)
        r.write_files_to({'/etc/hadoop/tt.incl':
                        utils.generate_fqdn_host_names(
                            inst_to_be_deleted))
        run.refresh_nodes(remote.get_remote(nn), "dfsadmin")
        context.sleep(3)
 

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v1_2_1/scaling.py   sahara(Download)
                        utils.generate_fqdn_host_names(
                            inst_to_be_deleted))
        run.refresh_nodes(remote.get_remote(jt), "mradmin")
        context.sleep(3)
        r.write_files_to({'/etc/hadoop/tt.incl':
                        utils.generate_fqdn_host_names(
                            inst_to_be_deleted))
        run.refresh_nodes(remote.get_remote(nn), "dfsadmin")
        context.sleep(3)