fix local flag in cluster health

This commit is contained in:
Shay Banon 2013-03-02 16:00:10 +01:00
parent 5dd18acd0e
commit 0be5a7888f
1 changed files with 5 additions and 0 deletions

View File

@ -74,6 +74,11 @@ public class TransportClusterHealthAction extends TransportMasterNodeOperationAc
return new ClusterHealthResponse();
}
@Override
protected boolean localExecute(ClusterHealthRequest request) {
return request.local();
}
@Override
protected ClusterHealthResponse masterOperation(ClusterHealthRequest request, ClusterState unusedState) throws ElasticSearchException {
long endTime = System.currentTimeMillis() + request.timeout().millis();