This is an automated email from the ASF dual-hosted git repository.
smengcl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 5f5a4586f4d HDDS-10711. Stabilize delete block command queue full test
(#11436)
5f5a4586f4d is described below
commit 5f5a4586f4dc75406e5e9a6f39f29b354ac9a21f
Author: KUAN-HAO HUANG <[email protected]>
AuthorDate: Sat Oct 10 16:47:45 2026 +0800
HDDS-10711. Stabilize delete block command queue full test (#11436)
---
.../statemachine/commandhandler/TestDeleteBlocksCommandHandler.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestDeleteBlocksCommandHandler.java
b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestDeleteBlocksCommandHandler.java
index a85f80ca373..b5563eeb18d 100644
---
a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestDeleteBlocksCommandHandler.java
+++
b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestDeleteBlocksCommandHandler.java
@@ -468,6 +468,8 @@ public void
testDeleteBlockCommandHandleWhenDeleteCommandQueuesFull()
dnConf.setBlockDeleteQueueLimit(blockDeleteQueueLimit);
handler = new DeleteBlocksCommandHandler(
container, configuration, dnConf, "");
+ // Stop the worker so that handle() can fill the queue without commands
being consumed.
+ handler.stop();
// Check if the command status is as expected: PENDING when queue is not
full, FAILED when queue is full
for (int i = 0; i < blockDeleteQueueLimit + 2; i++) {
@@ -482,6 +484,7 @@ public void
testDeleteBlockCommandHandleWhenDeleteCommandQueuesFull()
assertEquals(cmdStatus.getProtoBufMessage().getBlockDeletionAck().getResultsCount(),
0);
}
}
+ assertEquals(blockDeleteQueueLimit, handler.getQueuedCount());
}
@ContainerTestVersionInfo.ContainerTest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
