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

TEST: Index diff num docs in rolling upgrade tests (#34191) 

Today we index the same number of documents (50 documents) in each round
of the rolling upgrade tests. If the actual count does not match, we can
not guess the problematic round.

Relates #27650
This commit is contained in:
Nhat Nguyen 2018-10-02 09:04:03 -04:00 committed by GitHub
parent ead6ffce54
commit 7dbc403226
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
qa/rolling-upgrade/src/test/java/org/elasticsearch/upgrades/RecoveryIT.java
View File

@ -148,12 +148,12 @@ public class RecoveryIT extends AbstractRollingTestCase {
break; break;
case UPGRADED: case UPGRADED:
updateIndexSettings(index, Settings.builder().put(INDEX_ROUTING_ALLOCATION_ENABLE_SETTING.getKey(), (String)null)); updateIndexSettings(index, Settings.builder().put(INDEX_ROUTING_ALLOCATION_ENABLE_SETTING.getKey(), (String)null));
asyncIndexDocs(index, 60, 50).get(); asyncIndexDocs(index, 60, 45).get();
ensureGreen(index); ensureGreen(index);
client().performRequest(new Request("POST", index + "/_refresh")); client().performRequest(new Request("POST", index + "/_refresh"));
assertCount(index, "_only_nodes:" + nodes.get(0), 110); assertCount(index, "_only_nodes:" + nodes.get(0), 105);
assertCount(index, "_only_nodes:" + nodes.get(1), 110); assertCount(index, "_only_nodes:" + nodes.get(1), 105);
assertCount(index, "_only_nodes:" + nodes.get(2), 110); assertCount(index, "_only_nodes:" + nodes.get(2), 105);
break; break;
default: default:
throw new IllegalStateException("unknown type " + CLUSTER_TYPE); throw new IllegalStateException("unknown type " + CLUSTER_TYPE);
@ -165,7 +165,7 @@ public class RecoveryIT extends AbstractRollingTestCase {
request.addParameter("preference", preference); request.addParameter("preference", preference);
final Response response = client().performRequest(request); final Response response = client().performRequest(request);
final int actualCount = Integer.parseInt(ObjectPath.createFromResponse(response).evaluate("count").toString()); final int actualCount = Integer.parseInt(ObjectPath.createFromResponse(response).evaluate("count").toString());
assertThat(actualCount, equalTo(expectedCount)); assertThat("preference [" + preference + "]", actualCount, equalTo(expectedCount));
} }
@ -225,7 +225,7 @@ public class RecoveryIT extends AbstractRollingTestCase {
.put(IndexMetaData.INDEX_NUMBER_OF_REPLICAS_SETTING.getKey(), 2) .put(IndexMetaData.INDEX_NUMBER_OF_REPLICAS_SETTING.getKey(), 2)
.put("index.routing.allocation.include._id", (String)null) .put("index.routing.allocation.include._id", (String)null)
); );
asyncIndexDocs(index, 60, 50).get(); asyncIndexDocs(index, 60, 45).get();
ensureGreen(index); ensureGreen(index);
client().performRequest(new Request("POST", index + "/_refresh")); client().performRequest(new Request("POST", index + "/_refresh"));
Response response = client().performRequest(new Request("GET", "_nodes")); Response response = client().performRequest(new Request("GET", "_nodes"));
@ -233,9 +233,9 @@ public class RecoveryIT extends AbstractRollingTestCase {
final Map<String, Object> nodeMap = objectPath.evaluate("nodes"); final Map<String, Object> nodeMap = objectPath.evaluate("nodes");
List<String> nodes = new ArrayList<>(nodeMap.keySet()); List<String> nodes = new ArrayList<>(nodeMap.keySet());
assertCount(index, "_only_nodes:" + nodes.get(0), 110); assertCount(index, "_only_nodes:" + nodes.get(0), 105);
assertCount(index, "_only_nodes:" + nodes.get(1), 110); assertCount(index, "_only_nodes:" + nodes.get(1), 105);
assertCount(index, "_only_nodes:" + nodes.get(2), 110); assertCount(index, "_only_nodes:" + nodes.get(2), 105);
break; break;
default: default:
throw new IllegalStateException("unknown type " + CLUSTER_TYPE); throw new IllegalStateException("unknown type " + CLUSTER_TYPE);