2

我正在尝试通过 cloudera manager api (cm_api) 自动化一些 Hadoop 集群部署工作。到目前为止，我能够将新主机添加到 cloudera 管理器，添加到集群并使用此https://github.com/cloudera/cm_api/tree/master/python/src/cm_api/endpoints对其应用模板

现在我正在寻找一种方法来更新 YARN 服务中每个实例的角色配置，例如（yarn.nodemanager.local-dirs、yarn.nodemanager.resource.memory-mb、yarn.nodemanager.resource.cpu-vcores），具体取决于多少每个实例获得的磁盘、CPU 和内存。

任何人都知道如何在 python 中使用 cm_api 来做到这一点？

谢谢

4

1 回答 1

0 
service = cluster.get_service("YARN-" + p.get('cluster')['name'])
for role in service.get_all_role_config_groups():
    if 'NODEMANAGER' in role.roleType:
        role.update_config({"yarn_nodemanager_local_dirs": '/dfs/nm-local-dir'})
于 2015-08-25T17:28:58.110 回答