make sure to initialize the routing table version with the cluster state version as well

This commit is contained in:
kimchy 2011-06-12 14:39:44 +03:00
parent 5f4c6c75ae
commit ffc7f3e12b
1 changed files with 1 additions and 0 deletions

View File

@ -267,6 +267,7 @@ public class GatewayService extends AbstractLifecycleComponent<GatewayService> i
routingTableBuilder.add(indexRoutingBuilder); routingTableBuilder.add(indexRoutingBuilder);
} }
} }
routingTableBuilder.version(recoveredState.version());
// now, reroute // now, reroute
RoutingAllocation.Result routingResult = shardsAllocation.reroute(newClusterStateBuilder().state(updatedState).routingTable(routingTableBuilder).build()); RoutingAllocation.Result routingResult = shardsAllocation.reroute(newClusterStateBuilder().state(updatedState).routingTable(routingTableBuilder).build());