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

Reply via email to