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

Test: UpdateTests.stressUpdateDeleteConcurrency shouldn't turn off threaded operations 

This may result in all network threads being busy for too long.
This commit is contained in:
Boaz Leskes 2014-11-27 16:30:26 +01:00
parent 0c70b3ca7d
commit cd717ab8e7
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/test/java/org/elasticsearch/update/UpdateTests.java
View File

@ -724,7 +724,6 @@ public class UpdateTests extends ElasticsearchIntegrationTest {
.setScript("ctx._source.field += 1", ScriptService.ScriptType.INLINE) .setScript("ctx._source.field += 1", ScriptService.ScriptType.INLINE)
.setRetryOnConflict(retryOnConflict) .setRetryOnConflict(retryOnConflict)
.setUpsert(jsonBuilder().startObject().field("field", 1).endObject()) .setUpsert(jsonBuilder().startObject().field("field", 1).endObject())
.setListenerThreaded(false)
.request(); .request();
client().update(ur, new UpdateListener(j)); client().update(ur, new UpdateListener(j));
} catch (NoNodeAvailableException nne) { } catch (NoNodeAvailableException nne) {
@ -742,9 +741,7 @@ public class UpdateTests extends ElasticsearchIntegrationTest {
try { try {
deleteRequestsOutstanding.acquire(); deleteRequestsOutstanding.acquire();
DeleteRequest dr = client().prepareDelete("test", "type1", Integer.toString(j)) DeleteRequest dr = client().prepareDelete("test", "type1", Integer.toString(j)).request();
.setListenerThreaded(false)
.setOperationThreaded(false).request();
client().delete(dr, new DeleteListener(j)); client().delete(dr, new DeleteListener(j));
} catch (NoNodeAvailableException nne) { } catch (NoNodeAvailableException nne) {
deleteRequestsOutstanding.release(); deleteRequestsOutstanding.release();