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

Minor fix for the flaky test to reduce concurrency (#1361) (#1364) 

Fixes flakiness for test testReplicaThreadedThroughputDegradationAndRejection.

Reduced the number of threads concurrently executing from the initial range between (100-120) to a new range between (80-100), as the previous range was breaking the node limits set as 10kb, for every execution where number of threads were greater than 110.

Signed-off-by: Saurabh Singh <sisurab@amazon.com>
This commit is contained in:
Saurabh Singh 2021-10-15 03:55:17 +05:30 committed by GitHub
parent d151082832
commit 24fd89a1fd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/test/java/org/opensearch/index/ShardIndexingPressureConcurrentExecutionTests.java
View File

@ -484,7 +484,7 @@ public class ShardIndexingPressureConcurrentExecutionTests extends OpenSearchTes
.put(ShardIndexingPressureMemoryManager.THROUGHPUT_DEGRADATION_LIMITS.getKey(), 1) .put(ShardIndexingPressureMemoryManager.THROUGHPUT_DEGRADATION_LIMITS.getKey(), 1)
.put(ShardIndexingPressureSettings.REQUEST_SIZE_WINDOW.getKey(), 100) .put(ShardIndexingPressureSettings.REQUEST_SIZE_WINDOW.getKey(), 100)
.build(); .build();
final int NUM_THREADS = scaledRandomIntBetween(100, 120); final int NUM_THREADS = scaledRandomIntBetween(80, 100);
ShardIndexingPressure shardIndexingPressure = new ShardIndexingPressure(settings, clusterService); ShardIndexingPressure shardIndexingPressure = new ShardIndexingPressure(settings, clusterService);
Index index = new Index("IndexName", "UUID"); Index index = new Index("IndexName", "UUID");
ShardId shardId1 = new ShardId(index, 0); ShardId shardId1 = new ShardId(index, 0);