From d95aa9f266ccecf33894c88af329895c1693cd14 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Benjamin=20Deve=CC=80ze?= Date: Wed, 4 Jan 2012 23:37:34 +0100 Subject: [PATCH] add ttl tests with routing --- .../test/integration/ttl/SimpleTTLTests.java | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/src/test/java/org/elasticsearch/test/integration/ttl/SimpleTTLTests.java b/src/test/java/org/elasticsearch/test/integration/ttl/SimpleTTLTests.java index 89f4ab78fe1..3b8f00c041b 100644 --- a/src/test/java/org/elasticsearch/test/integration/ttl/SimpleTTLTests.java +++ b/src/test/java/org/elasticsearch/test/integration/ttl/SimpleTTLTests.java @@ -39,7 +39,12 @@ public class SimpleTTLTests extends AbstractNodesTests { @BeforeClass public void createNodes() throws Exception { - Settings settings = settingsBuilder().put("indices.ttl.interval", purgeInterval).build(); + Settings settings = settingsBuilder() + .put("indices.ttl.interval", purgeInterval) + .put("index.number_of_shards", 2) // 2 shards to test TTL purge with routing properly + .put("cluster.routing.operation.use_type", false) // make sure we control the shard computation + .put("cluster.routing.operation.hash.type", "djb") + .build(); startNode("node1", settings); startNode("node2", settings); client = getClient(); @@ -71,7 +76,9 @@ public class SimpleTTLTests extends AbstractNodesTests { client.admin().cluster().prepareHealth().setWaitForGreenStatus().execute().actionGet(); long providedTTLValue = 3000; logger.info("--> checking ttl"); + // Index one doc without routing and one doc with routing client.prepareIndex("test", "type1", "1").setSource("field1", "value1").setTTL(providedTTLValue).setRefresh(true).execute().actionGet(); + client.prepareIndex("test", "type1", "with_routing").setSource("field1", "value1").setTTL(providedTTLValue).setRouting("routing").setRefresh(true).execute().actionGet(); long now = System.currentTimeMillis(); // realtime get check @@ -100,7 +107,7 @@ public class SimpleTTLTests extends AbstractNodesTests { assertThat(ttl0, lessThan(providedTTLValue - (now1 - now))); logger.info("--> checking purger"); - // make sure the purger has done its job + // make sure the purger has done its job for all indexed docs that are expired long shouldBeExpiredDate = now + providedTTLValue + purgeInterval + 2000; now1 = System.currentTimeMillis(); if (shouldBeExpiredDate - now1 > 0) { @@ -109,14 +116,22 @@ public class SimpleTTLTests extends AbstractNodesTests { // realtime get check getResponse = client.prepareGet("test", "type1", "1").setFields("_ttl").setRealtime(true).execute().actionGet(); assertThat(getResponse.exists(), equalTo(false)); + getResponse = client.prepareGet("test", "type1", "with_routing").setRouting("routing").setFields("_ttl").setRealtime(true).execute().actionGet(); + assertThat(getResponse.exists(), equalTo(false)); // replica realtime get check getResponse = client.prepareGet("test", "type1", "1").setFields("_ttl").setRealtime(true).execute().actionGet(); assertThat(getResponse.exists(), equalTo(false)); + getResponse = client.prepareGet("test", "type1", "with_routing").setRouting("routing").setFields("_ttl").setRealtime(true).execute().actionGet(); + assertThat(getResponse.exists(), equalTo(false)); // non realtime get (stored) check getResponse = client.prepareGet("test", "type1", "1").setFields("_ttl").setRealtime(false).execute().actionGet(); assertThat(getResponse.exists(), equalTo(false)); + getResponse = client.prepareGet("test", "type1", "with_routing").setRouting("routing").setFields("_ttl").setRealtime(false).execute().actionGet(); + assertThat(getResponse.exists(), equalTo(false)); // non realtime get going the replica check getResponse = client.prepareGet("test", "type1", "1").setFields("_ttl").setRealtime(false).execute().actionGet(); assertThat(getResponse.exists(), equalTo(false)); + getResponse = client.prepareGet("test", "type1", "with_routing").setRouting("routing").setFields("_ttl").setRealtime(false).execute().actionGet(); + assertThat(getResponse.exists(), equalTo(false)); } }