|
|
@@ -126,7 +126,6 @@ import java.util.concurrent.CyclicBarrier;
|
|
|
import java.util.concurrent.atomic.AtomicBoolean;
|
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
-import java.util.function.IntFunction;
|
|
|
|
|
|
import static java.util.Collections.emptyMap;
|
|
|
import static org.elasticsearch.index.engine.Engine.Operation.Origin.PRIMARY;
|
|
|
@@ -172,10 +171,10 @@ public class InternalEngineTests extends ESTestCase {
|
|
|
codecName = "default";
|
|
|
}
|
|
|
defaultSettings = IndexSettingsModule.newIndexSettings("test", Settings.builder()
|
|
|
- .put(IndexSettings.INDEX_GC_DELETES_SETTING, "1h") // make sure this doesn't kick in on us
|
|
|
+ .put(IndexSettings.INDEX_GC_DELETES_SETTING.getKey(), "1h") // make sure this doesn't kick in on us
|
|
|
.put(EngineConfig.INDEX_CODEC_SETTING.getKey(), codecName)
|
|
|
.put(IndexMetaData.SETTING_VERSION_CREATED, Version.CURRENT)
|
|
|
- .put(IndexSettings.MAX_REFRESH_LISTENERS_PER_SHARD,
|
|
|
+ .put(IndexSettings.MAX_REFRESH_LISTENERS_PER_SHARD.getKey(),
|
|
|
between(10, 10 * IndexSettings.MAX_REFRESH_LISTENERS_PER_SHARD.get(Settings.EMPTY)))
|
|
|
.build()); // TODO randomize more settings
|
|
|
threadPool = new TestThreadPool(getClass().getName());
|