Skip to content

Commit 6bac16a

Browse files
committed
Relax condition, we may have renewed some other leases too
1 parent 7f7f84b commit 6bac16a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

server/src/test/java/org/elasticsearch/index/replication/RetentionLeasesReplicationTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@
3939

4040
import static org.hamcrest.Matchers.containsInAnyOrder;
4141
import static org.hamcrest.Matchers.equalTo;
42+
import static org.hamcrest.Matchers.greaterThan;
4243
import static org.hamcrest.Matchers.hasSize;
4344

4445
public class RetentionLeasesReplicationTests extends ESIndexLevelReplicationTestCase {
@@ -135,7 +136,7 @@ protected void syncRetentionLeases(ShardId shardId, RetentionLeases leases, Acti
135136
group.addRetentionLease("new-lease-after-promotion", randomNonNegativeLong(), "test", newLeaseFuture);
136137
RetentionLeases leasesOnPrimary = group.getPrimary().getRetentionLeases();
137138
assertThat(leasesOnPrimary.primaryTerm(), equalTo(group.getPrimary().getOperationPrimaryTerm()));
138-
assertThat(leasesOnPrimary.version(), equalTo(latestRetentionLeasesOnNewPrimary.version() + 1L));
139+
assertThat(leasesOnPrimary.version(), greaterThan(latestRetentionLeasesOnNewPrimary.version()));
139140
assertThat(leasesOnPrimary.leases(), hasSize(latestRetentionLeasesOnNewPrimary.leases().size() + 1));
140141
RetentionLeaseSyncAction.Request request = ((SyncRetentionLeasesResponse) newLeaseFuture.actionGet()).syncRequest;
141142
for (IndexShard replica : group.getReplicas()) {

0 commit comments

Comments
 (0)