How to ensure that rivers are equally distributed across nodes in the cluster