Hi,

I am trying to update the provisioner configuration.

public void setNumContainers(String appName, String serviceName, int
numContainers) {
    ResourceId resourceId = ResourceId.from(serviceName);

    ResourceAccessor resourceAccessor =
_connection.createResourceAccessor(ClusterId.from(appName));
    Resource resource = resourceAccessor.readResource(resourceId);
    LOG.info("Current provisioner config:"+
resource.getProvisionerConfig());

    ResourceConfig.Delta delta = new ResourceConfig.Delta(resourceId);
    YarnProvisionerConfig config = new YarnProvisionerConfig(resourceId);
    config.setNumContainers(numContainers);
    delta.setProvisionerConfig(config);
    ResourceConfig updatedResourceConfig =
resourceAccessor.updateResource(resourceId, delta);
    LOG.info("Update provisioner config:"+
updatedResourceConfig.getProvisionerConfig());

  }

Am i doing something wrong. This code is in helix-provisioning branch.

thanks,
Kishore G

Reply via email to