Add shard indexing pressure IT. (#478)

Signed-off-by: Saurabh Singh <sisurab@amazon.com>
getsaurabh02 · Apr 5, 2021 · 41c61e7 · 41c61e7
1 parent 657c705
commit 41c61e7
Show file tree

Hide file tree

Showing 2 changed files with 700 additions and 0 deletions.
diff --git a/server/src/internalClusterTest/java/org/opensearch/index/IndexingPressureIT.java b/server/src/internalClusterTest/java/org/opensearch/index/IndexingPressureIT.java
@@ -61,11 +61,15 @@ public class IndexingPressureIT extends OpenSearchIntegTestCase {
 
     private static final Settings unboundedWriteQueue = Settings.builder().put("thread_pool.write.queue_size", -1).build();
 
+    public static final Settings settings = Settings.builder()
+            .put(ShardIndexingPressureSettings.SHARD_INDEXING_PRESSURE_ENABLED.getKey(), false).build();
+
     @Override
     protected Settings nodeSettings(int nodeOrdinal) {
         return Settings.builder()
             .put(super.nodeSettings(nodeOrdinal))
             .put(unboundedWriteQueue)
+            .put(settings)
             .build();
     }