get shards should use preference as well when routing (fix wrong previous commit)
This commit is contained in:
parent
0bbf71188c
commit
cb0d89700c
|
@ -104,7 +104,7 @@ public class TransportGetAction extends TransportShardSingleOperationAction<GetR
|
||||||
|
|
||||||
@Override protected ShardIterator shards(ClusterState clusterState, GetRequest request) {
|
@Override protected ShardIterator shards(ClusterState clusterState, GetRequest request) {
|
||||||
return clusterService.operationRouting()
|
return clusterService.operationRouting()
|
||||||
.indexShards(clusterService.state(), request.index(), request.type(), request.id(), request.routing());
|
.getShards(clusterService.state(), request.index(), request.type(), request.id(), request.routing(), request.preference());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override protected void doExecute(GetRequest request, ActionListener<GetResponse> listener) {
|
@Override protected void doExecute(GetRequest request, ActionListener<GetResponse> listener) {
|
||||||
|
|
Loading…
Reference in New Issue