Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-13577: retrying TestReplicationHandler.doTestIndexFetchOnMasterRestart.

This commit is contained in:
Mikhail Khludnev 2019-06-26 14:15:39 +03:00
parent b54126169b
commit 48fb45e614
1 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
solr/core/src/test/org/apache/solr/handler/TestReplicationHandler.java
View File

@ -672,18 +672,27 @@ public class TestReplicationHandler extends SolrTestCaseJ4 {
masterJetty.start(); masterJetty.start();
// poll interval on slave is 1 second, so we just sleep for a few seconds // poll interval on slave is 1 second, so we just sleep for a few seconds
Thread.sleep(2000); for(int retries=0; ;retries++) {
Thread.sleep(2000);
try {
int failed = Integer.parseInt(getSlaveDetails("timesFailed"));
if (previousTimesFailed != null) {
assertTrue(failed > previousTimesFailed);
}
assertEquals(1, Integer.parseInt(getSlaveDetails("timesIndexReplicated")) - failed);
break;
} catch (NumberFormatException | AssertionError notYet) {
if (retries>9) {
throw notYet;
}
}
}
//get docs from slave and assert that they are still the same as before //get docs from slave and assert that they are still the same as before
slaveQueryRsp = rQuery(nDocs, "*:*", slaveClient); slaveQueryRsp = rQuery(nDocs, "*:*", slaveClient);
slaveQueryResult = (SolrDocumentList) slaveQueryRsp.get("response"); slaveQueryResult = (SolrDocumentList) slaveQueryRsp.get("response");
assertEquals(nDocs, numFound(slaveQueryRsp)); assertEquals(nDocs, numFound(slaveQueryRsp));
int failed = Integer.parseInt(getSlaveDetails("timesFailed"));
if (previousTimesFailed != null) {
assertTrue(failed > previousTimesFailed);
}
assertEquals(1, Integer.parseInt(getSlaveDetails("timesIndexReplicated")) - failed);
} finally { } finally {
resetFactory(); resetFactory();
} }