[TEST] Fixes primary term in TransportReplicationActionTests#testReplicaProxy

This commit is contained in:
Ali Beyad 2016-08-04 10:16:58 -04:00
parent 9f1525255a
commit 34bb150863
1 changed files with 1 additions and 1 deletions

View File

@ -534,7 +534,7 @@ public class TransportReplicationActionTests extends ESTestCase {
AtomicReference<Throwable> failure = new AtomicReference<>();
AtomicReference<Throwable> ignoredFailure = new AtomicReference<>();
AtomicBoolean success = new AtomicBoolean();
proxy.failShard(replica, randomIntBetween(0, 10), "test", new ElasticsearchException("simulated"),
proxy.failShard(replica, randomIntBetween(1, 10), "test", new ElasticsearchException("simulated"),
() -> success.set(true), failure::set, ignoredFailure::set
);
CapturingTransport.CapturedRequest[] shardFailedRequests = transport.getCapturedRequestsAndClear();