Skip to content

Commit

Permalink
Mute failing tests
Browse files Browse the repository at this point in the history 
Signed-off-by: Bhumika Saini <[email protected]>
  • Loading branch information
Bhumika Saini committed Jul 6, 2023
1 parent 23df688 commit 0361ada
Showing 1 changed file with 17 additions and 21 deletions.
38 changes: 17 additions & 21 deletions server/src/internalClusterTest/java/org/opensearch/remotestore/RemoteStoreIT.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -292,107 +292,107 @@ public void testRemoteTranslogRestoreWithCommittedData() throws IOException {
testRestoreFlow(true, randomIntBetween(2, 5), true);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates full data loss due to unrefreshed data, with no data restored from Remote Segment Store.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRSSRestoreWithNoDataPostCommitPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(false, 1, true);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates full data loss due to unrefreshed data, with no data restored from Remote Segment Store.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRSSRestoreWithNoDataPostRefreshPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(false, 1, false);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates data restored until the refreshed data in Remote Segment Store
* and data loss for the unrefreshed data.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRSSRestoreWithRefreshedDataPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(false, randomIntBetween(2, 5), false);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates data restored until the refreshed data in Remote Segment Store
* and data loss for the unrefreshed data.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRSSRestoreWithCommittedDataPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(false, randomIntBetween(2, 5), true);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/6188")
// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates all data restored using Remote Translog Store.
* @throws IOException IO Exception.
*/
// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/6188")
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRTSRestoreWithNoDataPostCommitPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(true, 1, true);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates all data restored using Remote Translog Store.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRTSRestoreWithNoDataPostRefreshPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(true, 1, false);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates refreshed data restored using Remote Segment Store
* and unrefreshed data restored using Remote Translog Store.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRTSRestoreWithRefreshedDataPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(true, randomIntBetween(2, 5), false);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
/**
* Simulates refreshed data restored using Remote Segment Store
* and unrefreshed data restored using Remote Translog Store.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8479")
public void testRTSRestoreWithCommittedDataPrimaryReplicaDown() throws IOException {
testRestoreFlowBothPrimaryReplicasDown(true, randomIntBetween(2, 5), true);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8480")
/**
* Simulates refreshed data restored using Remote Segment Store
* and unrefreshed data restored using Remote Translog Store
* for multiple indices matching a wildcard name pattern.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8480")
public void testRTSRestoreWithCommittedDataMultipleIndicesPatterns() throws IOException {
testRestoreFlowMultipleIndices(true, randomIntBetween(2, 5), true);
testRestoreFlowMultipleIndices(true, 2, true);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8480")
/**
* Simulates refreshed data restored using Remote Segment Store
* and unrefreshed data restored using Remote Translog Store,
* with all remote-enabled red indices considered for the restore by default.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8480")
public void testRTSRestoreWithCommittedDataDefaultAllIndices() throws IOException {
prepareCluster(1, 3, true, INDEX_NAMES, 1);
String[] indices = INDEX_NAMES.split(",");
Map<String, Map<String, Long>> indicesStats = new HashMap<>();
for (String index : indices) {
Map<String, Long> indexStats = indexData(randomIntBetween(2, 5), true, index);
Map<String, Long> indexStats = indexData(2, true, index);
indicesStats.put(index, indexStats);
}

Expand Down Expand Up @@ -429,11 +429,11 @@ public void testRTSRestoreWithCommittedDataDefaultAllIndices() throws IOExceptio
* @throws IOException IO Exception.
*/
public void testRTSRestoreWithCommittedDataNotAllRedRemoteIndices() throws IOException {
prepareCluster(1, 3, true, INDEX_NAMES, 1);
prepareCluster(1, 3, true, INDEX_NAMES, 0);
String[] indices = INDEX_NAMES.split(",");
Map<String, Map<String, Long>> indicesStats = new HashMap<>();
for (String index : indices) {
Map<String, Long> indexStats = indexData(randomIntBetween(2, 5), true, index);
Map<String, Long> indexStats = indexData(2, true, index);
indicesStats.put(index, indexStats);
}

Expand All @@ -442,10 +442,6 @@ public void testRTSRestoreWithCommittedDataNotAllRedRemoteIndices() throws IOExc
continue;
}

if (ClusterHealthStatus.GREEN.equals(ensureRed(index))) {
internalCluster().stopRandomNode(InternalTestCluster.nameFilter(replicaNodeName(index)));
}

internalCluster().stopRandomNode(InternalTestCluster.nameFilter(primaryNodeName(index)));
}

Expand All @@ -462,20 +458,20 @@ public void testRTSRestoreWithCommittedDataNotAllRedRemoteIndices() throws IOExc
ensureRed(indices[2], indices[3]);
}

// @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8480")
/**
* Simulates refreshed data restored using Remote Segment Store
* and unrefreshed data restored using Remote Translog Store,
* with all remote-enabled red indices being considered for the restore
* except those matching the specified exclusion pattern.
* @throws IOException IO Exception.
*/
@AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/8480")
public void testRTSRestoreWithCommittedDataExcludeIndicesPatterns() throws IOException {
prepareCluster(1, 3, true, INDEX_NAMES, 1);
String[] indices = INDEX_NAMES.split(",");
Map<String, Map<String, Long>> indicesStats = new HashMap<>();
for (String index : indices) {
Map<String, Long> indexStats = indexData(randomIntBetween(2, 5), true, index);
Map<String, Long> indexStats = indexData(2, true, index);
indicesStats.put(index, indexStats);
}

Expand Down

0 comments on commit 0361ada

Please sign in to comment.