This commit is contained in:
kimchy 2010-07-26 00:22:21 +03:00
parent ac7c8cb650
commit 03cd2f3772
1 changed files with 1 additions and 1 deletions

View File

@ -101,7 +101,7 @@ public class TransportClusterHealthAction extends TransportMasterNodeOperationAc
if (response.numberOfNodes() >= expected) {
waitForCounter++;
}
} else if (request.waitForNodes().startsWith("M=")) {
} else if (request.waitForNodes().startsWith("<=")) {
int expected = Integer.parseInt(request.waitForNodes().substring(2));
if (response.numberOfNodes() <= expected) {
waitForCounter++;