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

[TEST] Reenable RareClusterStateIt#testDeleteCreateInOneBulk 

The AwaitsFix issue has been closed as the deleting an index and recreating with same name will give the
shard a fresh folder to be written to (based on the index uuid).
This commit is contained in:
Yannick Welsch 2017-08-16 15:41:11 +08:00
parent 01f6851691
commit ca6eaf9831
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
core/src/test/java/org/elasticsearch/indices/state/RareClusterStateIT.java
View File

@ -172,21 +172,20 @@ public class RareClusterStateIT extends ESIntegTestCase {
}); });
} }
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/14932")
public void testDeleteCreateInOneBulk() throws Exception { public void testDeleteCreateInOneBulk() throws Exception {
internalCluster().startNodes(2); internalCluster().startMasterOnlyNode();
String dataNode = internalCluster().startDataOnlyNode();
assertFalse(client().admin().cluster().prepareHealth().setWaitForNodes("2").get().isTimedOut()); assertFalse(client().admin().cluster().prepareHealth().setWaitForNodes("2").get().isTimedOut());
prepareCreate("test").setSettings(IndexMetaData.SETTING_AUTO_EXPAND_REPLICAS, true).addMapping("type").get(); prepareCreate("test").setSettings(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0).addMapping("type").get();
ensureGreen("test"); ensureGreen("test");
// now that the cluster is stable, remove publishing timeout // now that the cluster is stable, remove publishing timeout
assertAcked(client().admin().cluster().prepareUpdateSettings().setTransientSettings(Settings.builder().put(DiscoverySettings.PUBLISH_TIMEOUT_SETTING.getKey(), "0"))); assertAcked(client().admin().cluster().prepareUpdateSettings().setTransientSettings(Settings.builder()
.put(DiscoverySettings.PUBLISH_TIMEOUT_SETTING.getKey(), "0")
Set<String> nodes = new HashSet<>(Arrays.asList(internalCluster().getNodeNames())); .put(DiscoverySettings.COMMIT_TIMEOUT_SETTING.getKey(), "30s")));
nodes.remove(internalCluster().getMasterName());
// block none master node. // block none master node.
BlockClusterStateProcessing disruption = new BlockClusterStateProcessing(nodes.iterator().next(), random()); BlockClusterStateProcessing disruption = new BlockClusterStateProcessing(dataNode, random());
internalCluster().setDisruptionScheme(disruption); internalCluster().setDisruptionScheme(disruption);
logger.info("--> indexing a doc"); logger.info("--> indexing a doc");
index("test", "type", "1"); index("test", "type", "1");
@ -194,7 +193,8 @@ public class RareClusterStateIT extends ESIntegTestCase {
disruption.startDisrupting(); disruption.startDisrupting();
logger.info("--> delete index and recreate it"); logger.info("--> delete index and recreate it");
assertFalse(client().admin().indices().prepareDelete("test").setTimeout("200ms").get().isAcknowledged()); assertFalse(client().admin().indices().prepareDelete("test").setTimeout("200ms").get().isAcknowledged());
assertFalse(prepareCreate("test").setTimeout("200ms").setSettings(IndexMetaData.SETTING_AUTO_EXPAND_REPLICAS, true).get().isAcknowledged()); assertFalse(prepareCreate("test").setTimeout("200ms").setSettings(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0,
IndexMetaData.SETTING_WAIT_FOR_ACTIVE_SHARDS.getKey(), "0").get().isAcknowledged());
logger.info("--> letting cluster proceed"); logger.info("--> letting cluster proceed");
disruption.stopDisrupting(); disruption.stopDisrupting();
ensureGreen(TimeValue.timeValueMinutes(30), "test"); ensureGreen(TimeValue.timeValueMinutes(30), "test");