Skip to content

Commit 830def1

Browse files
author
Andrey Ershov
committed
Revert testDanglingIndices, except TODO
1 parent edfa48a commit 830def1

File tree

1 file changed

+7
-9
lines changed

1 file changed

+7
-9
lines changed

server/src/test/java/org/elasticsearch/gateway/GatewayIndexStateIT.java

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -282,12 +282,9 @@ public void testDanglingIndices() throws Exception {
282282
Consider adding term to JoinRequest, so that master node can bump its term if its current term is less than JoinRequest#term.
283283
*/
284284
logger.info("--> starting two nodes");
285-
String masterNode = internalCluster().startNode(Settings.builder()
286-
.put(Settings.builder().put(TestZenDiscovery.USE_ZEN2.getKey(), false).build())
287-
.build());
288-
internalCluster().startDataOnlyNode(Settings.builder()
289-
.put(Settings.builder().put(TestZenDiscovery.USE_ZEN2.getKey(), false).build())
290-
.build());
285+
286+
final String node_1 = internalCluster().startNodes(2,
287+
Settings.builder().put(TestZenDiscovery.USE_ZEN2.getKey(), false).build()).get(0);
291288

292289
logger.info("--> indexing a simple document");
293290
client().prepareIndex("test", "type1", "1").setSource("field1", "value1").setRefreshPolicy(IMMEDIATE).get();
@@ -301,11 +298,11 @@ public void testDanglingIndices() throws Exception {
301298
}
302299
assertThat(client().prepareGet("test", "type1", "1").execute().actionGet().isExists(), equalTo(true));
303300

304-
logger.info("--> restarting master node, while clearing its data");
305-
internalCluster().restartNode(masterNode, new RestartCallback() {
301+
logger.info("--> restarting the nodes");
302+
internalCluster().fullRestart(new RestartCallback() {
306303
@Override
307304
public boolean clearData(String nodeName) {
308-
return true;
305+
return node_1.equals(nodeName);
309306
}
310307
});
311308

@@ -362,6 +359,7 @@ public Settings onNodeStopped(final String nodeName) throws Exception {
362359
final Client client = client(otherNode);
363360
client.admin().indices().prepareDelete(indexName).execute().actionGet();
364361
assertFalse(client.admin().indices().prepareExists(indexName).execute().actionGet().isExists());
362+
logger.info("--> index deleted");
365363
return super.onNodeStopped(nodeName);
366364
}
367365
});

0 commit comments

Comments
 (0)