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

Slow down monitoring bwc test so it can shut down 

We only need it to be so fast when starting up. We can slow it
down once it has started so shutdown isn't problematic.

Original commit: elastic/x-pack-elasticsearch@052d64402f
This commit is contained in:
Nik Everett 2016-11-03 17:22:02 -04:00
parent ac7b617f02
commit 784e40ac6c
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
elasticsearch/src/test/java/org/elasticsearch/xpack/monitoring/OldMonitoringIndicesBackwardsCompatibilityIT.java
View File

@ -34,6 +34,8 @@ import java.util.Set;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import static org.elasticsearch.common.unit.TimeValue.timeValueMillis; import static org.elasticsearch.common.unit.TimeValue.timeValueMillis;
import static org.elasticsearch.common.unit.TimeValue.timeValueSeconds;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertHitCount; import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertHitCount;
import static org.hamcrest.Matchers.allOf; import static org.hamcrest.Matchers.allOf;
import static org.hamcrest.Matchers.greaterThan; import static org.hamcrest.Matchers.greaterThan;
@ -106,6 +108,11 @@ public class OldMonitoringIndicesBackwardsCompatibilityIT extends AbstractOldXPa
IndexStatsResolver resolver = new IndexStatsResolver(MonitoredSystem.ES, Settings.EMPTY); IndexStatsResolver resolver = new IndexStatsResolver(MonitoredSystem.ES, Settings.EMPTY);
logger.info("--> {} Waiting for [{}]", Thread.currentThread().getName(), resolver.indexPattern()); logger.info("--> {} Waiting for [{}]", Thread.currentThread().getName(), resolver.indexPattern());
assertBusy(() -> assertTrue(client().admin().indices().prepareExists(resolver.indexPattern()).get().isExists())); assertBusy(() -> assertTrue(client().admin().indices().prepareExists(resolver.indexPattern()).get().isExists()));
// Slow down monitoring from its previously super fast pace so we can shut down without trouble
Settings.Builder settings = Settings.builder()
.put(MonitoringSettings.INTERVAL.getKey(), timeValueSeconds(10).getStringRep());
assertAcked(client().admin().cluster().prepareUpdateSettings().setTransientSettings(settings).get());
SearchResponse firstIndexStats = search(resolver, greaterThanOrEqualTo(10L)); SearchResponse firstIndexStats = search(resolver, greaterThanOrEqualTo(10L));
// All the other aliases should have been created by now so we can assert that we have the data we saved in the bwc indexes // All the other aliases should have been created by now so we can assert that we have the data we saved in the bwc indexes