|
@@ -21,7 +21,7 @@ package org.elasticsearch.test;
|
|
|
import com.carrotsearch.randomizedtesting.RandomizedTest;
|
|
|
import com.carrotsearch.randomizedtesting.SeedUtils;
|
|
|
import com.carrotsearch.randomizedtesting.SysGlobals;
|
|
|
-import com.carrotsearch.randomizedtesting.generators.RandomInts;
|
|
|
+import com.carrotsearch.randomizedtesting.generators.RandomNumbers;
|
|
|
import com.carrotsearch.randomizedtesting.generators.RandomPicks;
|
|
|
import com.carrotsearch.randomizedtesting.generators.RandomStrings;
|
|
|
import org.apache.logging.log4j.Logger;
|
|
@@ -249,7 +249,7 @@ public final class InternalTestCluster extends TestCluster {
|
|
|
|
|
|
boolean useDedicatedMasterNodes = randomlyAddDedicatedMasters ? random.nextBoolean() : false;
|
|
|
|
|
|
- this.numSharedDataNodes = RandomInts.randomIntBetween(random, minNumDataNodes, maxNumDataNodes);
|
|
|
+ this.numSharedDataNodes = RandomNumbers.randomIntBetween(random, minNumDataNodes, maxNumDataNodes);
|
|
|
assert this.numSharedDataNodes >= 0;
|
|
|
|
|
|
if (numSharedDataNodes == 0) {
|
|
@@ -267,7 +267,7 @@ public final class InternalTestCluster extends TestCluster {
|
|
|
this.numSharedDedicatedMasterNodes = 0;
|
|
|
}
|
|
|
if (numClientNodes < 0) {
|
|
|
- this.numSharedCoordOnlyNodes = RandomInts.randomIntBetween(random, DEFAULT_MIN_NUM_CLIENT_NODES, DEFAULT_MAX_NUM_CLIENT_NODES);
|
|
|
+ this.numSharedCoordOnlyNodes = RandomNumbers.randomIntBetween(random, DEFAULT_MIN_NUM_CLIENT_NODES, DEFAULT_MAX_NUM_CLIENT_NODES);
|
|
|
} else {
|
|
|
this.numSharedCoordOnlyNodes = numClientNodes;
|
|
|
}
|
|
@@ -321,14 +321,14 @@ public final class InternalTestCluster extends TestCluster {
|
|
|
// Some tests make use of scripting quite a bit, so increase the limit for integration tests
|
|
|
builder.put(ScriptService.SCRIPT_MAX_COMPILATIONS_PER_MINUTE.getKey(), 1000);
|
|
|
if (TEST_NIGHTLY) {
|
|
|
- builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_INCOMING_RECOVERIES_SETTING.getKey(), RandomInts.randomIntBetween(random, 5, 10));
|
|
|
- builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_OUTGOING_RECOVERIES_SETTING.getKey(), RandomInts.randomIntBetween(random, 5, 10));
|
|
|
+ builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_INCOMING_RECOVERIES_SETTING.getKey(), RandomNumbers.randomIntBetween(random, 5, 10));
|
|
|
+ builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_OUTGOING_RECOVERIES_SETTING.getKey(), RandomNumbers.randomIntBetween(random, 5, 10));
|
|
|
} else if (random.nextInt(100) <= 90) {
|
|
|
- builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_INCOMING_RECOVERIES_SETTING.getKey(), RandomInts.randomIntBetween(random, 2, 5));
|
|
|
- builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_OUTGOING_RECOVERIES_SETTING.getKey(), RandomInts.randomIntBetween(random, 2, 5));
|
|
|
+ builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_INCOMING_RECOVERIES_SETTING.getKey(), RandomNumbers.randomIntBetween(random, 2, 5));
|
|
|
+ builder.put(ThrottlingAllocationDecider.CLUSTER_ROUTING_ALLOCATION_NODE_CONCURRENT_OUTGOING_RECOVERIES_SETTING.getKey(), RandomNumbers.randomIntBetween(random, 2, 5));
|
|
|
}
|
|
|
// always reduce this - it can make tests really slow
|
|
|
- builder.put(RecoverySettings.INDICES_RECOVERY_RETRY_DELAY_STATE_SYNC_SETTING.getKey(), TimeValue.timeValueMillis(RandomInts.randomIntBetween(random, 20, 50)));
|
|
|
+ builder.put(RecoverySettings.INDICES_RECOVERY_RETRY_DELAY_STATE_SYNC_SETTING.getKey(), TimeValue.timeValueMillis(RandomNumbers.randomIntBetween(random, 20, 50)));
|
|
|
defaultSettings = builder.build();
|
|
|
executor = EsExecutors.newScaling("test runner", 0, Integer.MAX_VALUE, 0, TimeUnit.SECONDS, EsExecutors.daemonThreadFactory("test_" + clusterName), new ThreadContext(Settings.EMPTY));
|
|
|
}
|
|
@@ -396,7 +396,7 @@ public final class InternalTestCluster extends TestCluster {
|
|
|
}
|
|
|
|
|
|
if (random.nextBoolean()) {
|
|
|
- builder.put(MappingUpdatedAction.INDICES_MAPPING_DYNAMIC_TIMEOUT_SETTING.getKey(), new TimeValue(RandomInts.randomIntBetween(random, 10, 30), TimeUnit.SECONDS));
|
|
|
+ builder.put(MappingUpdatedAction.INDICES_MAPPING_DYNAMIC_TIMEOUT_SETTING.getKey(), new TimeValue(RandomNumbers.randomIntBetween(random, 10, 30), TimeUnit.SECONDS));
|
|
|
}
|
|
|
|
|
|
if (random.nextInt(10) == 0) {
|
|
@@ -406,9 +406,9 @@ public final class InternalTestCluster extends TestCluster {
|
|
|
|
|
|
if (random.nextBoolean()) {
|
|
|
if (random.nextInt(10) == 0) { // do something crazy slow here
|
|
|
- builder.put(IndexStoreConfig.INDICES_STORE_THROTTLE_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomInts.randomIntBetween(random, 1, 10), ByteSizeUnit.MB));
|
|
|
+ builder.put(IndexStoreConfig.INDICES_STORE_THROTTLE_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomNumbers.randomIntBetween(random, 1, 10), ByteSizeUnit.MB));
|
|
|
} else {
|
|
|
- builder.put(IndexStoreConfig.INDICES_STORE_THROTTLE_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomInts.randomIntBetween(random, 10, 200), ByteSizeUnit.MB));
|
|
|
+ builder.put(IndexStoreConfig.INDICES_STORE_THROTTLE_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomNumbers.randomIntBetween(random, 10, 200), ByteSizeUnit.MB));
|
|
|
}
|
|
|
}
|
|
|
if (random.nextBoolean()) {
|
|
@@ -417,21 +417,21 @@ public final class InternalTestCluster extends TestCluster {
|
|
|
|
|
|
if (random.nextBoolean()) {
|
|
|
if (random.nextInt(10) == 0) { // do something crazy slow here
|
|
|
- builder.put(RecoverySettings.INDICES_RECOVERY_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomInts.randomIntBetween(random, 1, 10), ByteSizeUnit.MB));
|
|
|
+ builder.put(RecoverySettings.INDICES_RECOVERY_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomNumbers.randomIntBetween(random, 1, 10), ByteSizeUnit.MB));
|
|
|
} else {
|
|
|
- builder.put(RecoverySettings.INDICES_RECOVERY_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomInts.randomIntBetween(random, 10, 200), ByteSizeUnit.MB));
|
|
|
+ builder.put(RecoverySettings.INDICES_RECOVERY_MAX_BYTES_PER_SEC_SETTING.getKey(), new ByteSizeValue(RandomNumbers.randomIntBetween(random, 10, 200), ByteSizeUnit.MB));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (random.nextBoolean()) {
|
|
|
- builder.put(TcpTransport.PING_SCHEDULE.getKey(), RandomInts.randomIntBetween(random, 100, 2000) + "ms");
|
|
|
+ builder.put(TcpTransport.PING_SCHEDULE.getKey(), RandomNumbers.randomIntBetween(random, 100, 2000) + "ms");
|
|
|
}
|
|
|
|
|
|
if (random.nextBoolean()) {
|
|
|
- builder.put(ScriptService.SCRIPT_CACHE_SIZE_SETTING.getKey(), RandomInts.randomIntBetween(random, 0, 2000));
|
|
|
+ builder.put(ScriptService.SCRIPT_CACHE_SIZE_SETTING.getKey(), RandomNumbers.randomIntBetween(random, 0, 2000));
|
|
|
}
|
|
|
if (random.nextBoolean()) {
|
|
|
- builder.put(ScriptService.SCRIPT_CACHE_EXPIRE_SETTING.getKey(), TimeValue.timeValueMillis(RandomInts.randomIntBetween(random, 750, 10000000)).getStringRep());
|
|
|
+ builder.put(ScriptService.SCRIPT_CACHE_EXPIRE_SETTING.getKey(), TimeValue.timeValueMillis(RandomNumbers.randomIntBetween(random, 750, 10000000)).getStringRep());
|
|
|
}
|
|
|
|
|
|
return builder.build();
|