@@ -201,13 +201,16 @@ public void testEquivalence() throws Exception {
201201 for (int i = 0 ; i < numDocs ; i ++) {
202202 client ().prepareIndex ("test" , "type1" , String .valueOf (i )).setSource ("field1" , English .intToEnglish (i )).execute ().actionGet ();
203203 }
204-
205- client ().admin ().indices ().prepareRefresh ("test" ).execute ().actionGet ();
204+
205+ flush ();
206+ optimize (); // make sure we don't have a background merge running
207+ refresh ();
206208 for (int i = 0 ; i < numDocs ; i ++) {
207209 String intToEnglish = English .intToEnglish (i );
208210 String query = intToEnglish .split (" " )[0 ];
209211 SearchResponse rescored = client ()
210212 .prepareSearch ()
213+ .setPreference ("test" ) // ensure we hit the same shards for tie-breaking
211214 .setQuery (QueryBuilders .matchQuery ("field1" , query ).operator (MatchQueryBuilder .Operator .OR ))
212215 .setFrom (0 )
213216 .setSize (10 )
@@ -222,13 +225,15 @@ public void testEquivalence() throws Exception {
222225
223226
224227 SearchResponse plain = client ().prepareSearch ()
228+ .setPreference ("test" ) // ensure we hit the same shards for tie-breaking
225229 .setQuery (QueryBuilders .matchQuery ("field1" , query ).operator (MatchQueryBuilder .Operator .OR )).setFrom (0 ).setSize (10 )
226230 .execute ().actionGet ();
227231 // check equivalence
228232 assertEquivalent (plain , rescored );
229233
230234 rescored = client ()
231235 .prepareSearch ()
236+ .setPreference ("test" ) // ensure we hit the same shards for tie-breaking
232237 .setQuery (QueryBuilders .matchQuery ("field1" , query ).operator (MatchQueryBuilder .Operator .OR ))
233238 .setFrom (0 )
234239 .setSize (10 )
@@ -245,6 +250,7 @@ public void testEquivalence() throws Exception {
245250
246251 rescored = client ()
247252 .prepareSearch ()
253+ .setPreference ("test" ) // ensure we hit the same shards for tie-breaking
248254 .setQuery (QueryBuilders .matchQuery ("field1" , query ).operator (MatchQueryBuilder .Operator .OR ))
249255 .setFrom (0 )
250256 .setSize (10 )
0 commit comments