From 11fd9d924f86db8d70c53c2adf253e4e9bfc4a69 Mon Sep 17 00:00:00 2001 From: Bukhtawar Khan Date: Sat, 2 Sep 2023 13:30:25 +0530 Subject: [PATCH] Disabling tests as write thread pool block on replica doesn't impact primary term validation on transport worker Signed-off-by: Bukhtawar Khan --- .../org/opensearch/index/ShardIndexingPressureIT.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/server/src/internalClusterTest/java/org/opensearch/index/ShardIndexingPressureIT.java b/server/src/internalClusterTest/java/org/opensearch/index/ShardIndexingPressureIT.java index 69c394d2da133..0fc50a3913cf1 100644 --- a/server/src/internalClusterTest/java/org/opensearch/index/ShardIndexingPressureIT.java +++ b/server/src/internalClusterTest/java/org/opensearch/index/ShardIndexingPressureIT.java @@ -75,6 +75,8 @@ protected int numberOfShards() { return 1; } + @AwaitsFix(bugUrl = "The tests blocks write threadpool on replica to mimic replication getting stuck. Since primary term validation is pretty light-weight we use transport_worker instead and the backpressure" + + " for segrep is dealt with differently hence skipping") public void testShardIndexingPressureTrackingDuringBulkWrites() throws Exception { assertAcked( prepareCreate( @@ -266,6 +268,8 @@ public void testShardIndexingPressureTrackingDuringBulkWrites() throws Exception } } + @AwaitsFix(bugUrl = "The tests blocks write threadpool on replica to mimic replication getting stuck. Since primary term validation is pretty light-weight we use transport_worker instead and the backpressure" + + " for segrep is dealt with differently hence skipping") public void testWritesRejectedForSingleCoordinatingShardDueToNodeLevelLimitBreach() throws Exception { final BulkRequest bulkRequest = new BulkRequest(); int totalRequestSize = 0; @@ -354,6 +358,8 @@ public void testWritesRejectedForSingleCoordinatingShardDueToNodeLevelLimitBreac } } + @AwaitsFix(bugUrl = "The tests blocks write threadpool on replica to mimic replication getting stuck. Since primary term validation is pretty light-weight we use transport_worker instead and the backpressure" + + " for segrep is dealt with differently hence skipping") public void testWritesRejectedFairnessWithMultipleCoordinatingShardsDueToNodeLevelLimitBreach() throws Exception { final BulkRequest largeBulkRequest = new BulkRequest(); int totalRequestSize = 0; @@ -518,6 +524,8 @@ public void testWritesRejectedFairnessWithMultipleCoordinatingShardsDueToNodeLev } } + @AwaitsFix(bugUrl = "The tests blocks write threadpool on replica to mimic replication getting stuck. Since primary term validation is pretty light-weight we use transport_worker instead and the backpressure" + + " for segrep is dealt with differently hence skipping") public void testWritesRejectedForSinglePrimaryShardDueToNodeLevelLimitBreach() throws Exception { final BulkRequest bulkRequest = new BulkRequest(); int totalRequestSize = 0; @@ -598,6 +606,8 @@ public void testWritesRejectedForSinglePrimaryShardDueToNodeLevelLimitBreach() t } } + @AwaitsFix(bugUrl = "The tests blocks write threadpool on replica to mimic replication getting stuck. Since primary term validation is pretty light-weight we use transport_worker instead and the backpressure" + + " for segrep is dealt with differently hence skipping") public void testWritesRejectedFairnessWithMultiplePrimaryShardsDueToNodeLevelLimitBreach() throws Exception { final BulkRequest largeBulkRequest = new BulkRequest(); int totalRequestSize = 0;