I am working through the tutorial on the User-Defined Rebalancing and I am
not able to get my Rebalancer to be invoked.
Sample Code
======
public static void main(String[] args) {
ZKHelixAdmin admin = new ZKHelixAdmin(Conf.ZK_ADDRESS);
IdealState idealState =
admin.getResourceIdealState(Conf.CLUSTER_NAME, Conf.RESOURCE_NAME);
idealState.setRebalanceMode(IdealState.RebalanceMode.USER_DEFINED);
idealState.setRebalancerClassName(MyRebalancer.class.getName());
admin.setResourceIdealState(Conf.CLUSTER_NAME, Conf.RESOURCE_NAME,
idealState);
admin.rebalance(Conf.CLUSTER_NAME, RESOURCE_NAME, NUM_REPLICAS);
}
======
I was expecting that when calling the "admin.rebalance" method, it would
invoke "MyRebalance" code but when I run it "MyRebalance" code was not
invoked.
Thanks,
Rob