File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
modules/elasticsearch/src/main/java/org/elasticsearch/cluster/routing Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 25
25
import org .elasticsearch .cluster .ClusterState ;
26
26
import org .elasticsearch .cluster .ClusterStateListener ;
27
27
import org .elasticsearch .cluster .ClusterStateUpdateTask ;
28
+ import org .elasticsearch .cluster .node .DiscoveryNode ;
28
29
import org .elasticsearch .cluster .routing .allocation .RoutingAllocation ;
29
30
import org .elasticsearch .cluster .routing .allocation .ShardsAllocation ;
30
31
import org .elasticsearch .common .component .AbstractLifecycleComponent ;
@@ -103,7 +104,12 @@ public class RoutingService extends AbstractLifecycleComponent<RoutingService> i
103
104
// reroute();
104
105
} else {
105
106
if (event .nodesAdded ()) {
106
- routingTableDirty = true ;
107
+ for (DiscoveryNode node : event .nodesDelta ().addedNodes ()) {
108
+ if (node .dataNode ()) {
109
+ routingTableDirty = true ;
110
+ break ;
111
+ }
112
+ }
107
113
}
108
114
}
109
115
} else {
You can’t perform that action at this time.
0 commit comments