honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

TEST: Adjust rollback condition when shard is empty 

If a shard is empty, it won't rollback its engine on promotion.
This commit adjusts the expectation in the rollback test.

Relates #33473
This commit is contained in:
Nhat Nguyen 2018-09-12 08:24:11 -04:00
parent 96c49e5ed0
commit d9bbb89b26
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/test/java/org/elasticsearch/index/shard/IndexShardTests.java
View File

@ -963,7 +963,8 @@ public class IndexShardTests extends IndexShardTestCase {
Set<String> docsBelowGlobalCheckpoint = getShardDocUIDs(indexShard).stream() Set<String> docsBelowGlobalCheckpoint = getShardDocUIDs(indexShard).stream()
.filter(id -> Long.parseLong(id) <= Math.max(globalCheckpointOnReplica, globalCheckpoint)).collect(Collectors.toSet()); .filter(id -> Long.parseLong(id) <= Math.max(globalCheckpointOnReplica, globalCheckpoint)).collect(Collectors.toSet());
final CountDownLatch latch = new CountDownLatch(1); final CountDownLatch latch = new CountDownLatch(1);
final boolean shouldRollback = Math.max(globalCheckpoint, globalCheckpointOnReplica) < indexShard.seqNoStats().getMaxSeqNo(); final boolean shouldRollback = Math.max(globalCheckpoint, globalCheckpointOnReplica) < indexShard.seqNoStats().getMaxSeqNo()
&& indexShard.seqNoStats().getMaxSeqNo() != SequenceNumbers.NO_OPS_PERFORMED;
final Engine beforeRollbackEngine = indexShard.getEngine(); final Engine beforeRollbackEngine = indexShard.getEngine();
indexShard.acquireReplicaOperationPermit( indexShard.acquireReplicaOperationPermit(
indexShard.pendingPrimaryTerm + 1, indexShard.pendingPrimaryTerm + 1,