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