From 2cc4a286f8ac043be4c3cf6afce2c7cc6790a4b1 Mon Sep 17 00:00:00 2001 From: kimchy Date: Sat, 16 Apr 2011 03:23:47 +0300 Subject: [PATCH] small refactor --- .../indexing/ConcurrentIndexingVersioningTest.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/modules/test/integration/src/test/java/org/elasticsearch/test/stress/indexing/ConcurrentIndexingVersioningTest.java b/modules/test/integration/src/test/java/org/elasticsearch/test/stress/indexing/ConcurrentIndexingVersioningTest.java index a56af7f70f8..ce950ffe83a 100644 --- a/modules/test/integration/src/test/java/org/elasticsearch/test/stress/indexing/ConcurrentIndexingVersioningTest.java +++ b/modules/test/integration/src/test/java/org/elasticsearch/test/stress/indexing/ConcurrentIndexingVersioningTest.java @@ -80,17 +80,18 @@ public class ConcurrentIndexingVersioningTest { System.out.println("done indexing, verifying docs"); client.client().admin().indices().prepareRefresh().execute().actionGet(); for (int i = 0; i < NUMBER_OF_DOCS; i++) { + String id = Integer.toString(i); for (int j = 0; j < 5; j++) { - SearchResponse response = client.client().prepareSearch().setQuery(QueryBuilders.termQuery("_id", Integer.toString(i))).execute().actionGet(); + SearchResponse response = client.client().prepareSearch().setQuery(QueryBuilders.termQuery("_id", id)).execute().actionGet(); if (response.hits().totalHits() > 1) { System.err.println("[" + i + "] FAIL, HITS [" + response.hits().totalHits() + "]"); } } - GetResponse getResponse = client.client().prepareGet("test", "type1", Integer.toString(i)).execute().actionGet(); + GetResponse getResponse = client.client().prepareGet("test", "type1", id).execute().actionGet(); if (getResponse.exists()) { long version = getResponse.version(); for (int j = 0; j < 5; j++) { - getResponse = client.client().prepareGet("test", "type1", Integer.toString(i)).execute().actionGet(); + getResponse = client.client().prepareGet("test", "type1", id).execute().actionGet(); if (!getResponse.exists()) { System.err.println("[" + i + "] FAIL, EXISTED, and NOT_EXISTED"); break; @@ -102,7 +103,7 @@ public class ConcurrentIndexingVersioningTest { } } else { for (int j = 0; j < 5; j++) { - getResponse = client.client().prepareGet("test", "type1", Integer.toString(i)).execute().actionGet(); + getResponse = client.client().prepareGet("test", "type1", id).execute().actionGet(); if (getResponse.exists()) { System.err.println("[" + i + "] FAIL, EXISTED, and NOT_EXISTED"); break;