Skip to content

Commit

Permalink
Removing asserts based on translog stats as it is not applicable for …
Browse files Browse the repository at this point in the history
…remote store (opensearch-project#9878)

Signed-off-by: Gaurav Bafna <[email protected]>
Signed-off-by: Kaushal Kumar <[email protected]>
  • Loading branch information
gbbafna authored and kaushalmahi12 committed Sep 12, 2023
1 parent ac160d7 commit d2e481b
Showing 1 changed file with 0 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,22 +81,18 @@ protected ReplicationGroup getReplicationGroup(int numberOfReplicas) throws IOEx
return createGroup(numberOfReplicas, settings, indexMapping, new NRTReplicationEngineFactory(), createTempDir());
}

@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/9624")
public void testNRTReplicaWithRemoteStorePromotedAsPrimaryRefreshRefresh() throws Exception {
testNRTReplicaWithRemoteStorePromotedAsPrimary(false, false);
}

@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/9624")
public void testNRTReplicaWithRemoteStorePromotedAsPrimaryRefreshCommit() throws Exception {
testNRTReplicaWithRemoteStorePromotedAsPrimary(false, true);
}

@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/9624")
public void testNRTReplicaWithRemoteStorePromotedAsPrimaryCommitRefresh() throws Exception {
testNRTReplicaWithRemoteStorePromotedAsPrimary(true, false);
}

@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/9624")
public void testNRTReplicaWithRemoteStorePromotedAsPrimaryCommitCommit() throws Exception {
testNRTReplicaWithRemoteStorePromotedAsPrimary(true, true);
}
Expand Down Expand Up @@ -156,10 +152,6 @@ public void testNRTReplicaWithRemoteStorePromotedAsPrimary(boolean performFlushF
assertEquals(InternalEngine.class, nextPrimary.getEngine().getClass());
assertDocCounts(nextPrimary, totalDocs, totalDocs);

// As we are downloading segments from remote segment store on failover, there should not be
// any operations replayed from translog
assertEquals(prevOperationCount, nextPrimary.translogStats().estimatedNumberOfOperations());

// refresh and push segments to our other replica.
nextPrimary.refresh("test");

Expand Down

0 comments on commit d2e481b

Please sign in to comment.