From aaad291892fbea6ad10973e82031a438a6f8da40 Mon Sep 17 00:00:00 2001 From: "Doroszlai, Attila" Date: Tue, 11 Feb 2025 11:15:54 +0100 Subject: [PATCH] HDDS-12309. Intermittent failure in TestCloseContainerCommandHandler.testThreadPoolPoolSize --- .../TestCloseContainerCommandHandler.java | 19 ------------------- 1 file changed, 19 deletions(-) diff --git a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerCommandHandler.java b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerCommandHandler.java index 2e1e0eafd017..1251a33072f5 100644 --- a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerCommandHandler.java +++ b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerCommandHandler.java @@ -44,7 +44,6 @@ import static org.apache.hadoop.ozone.OzoneConsts.GB; import static org.assertj.core.api.Assertions.assertThat; import static org.junit.jupiter.api.Assertions.assertThrows; -import static org.junit.jupiter.api.Assertions.assertTrue; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.mockito.Mockito.any; import static org.mockito.Mockito.eq; @@ -296,24 +295,6 @@ private void waitTillFinishExecution( @Test public void testThreadPoolPoolSize() { assertEquals(1, subject.getThreadPoolMaxPoolSize()); - assertEquals(0, subject.getThreadPoolActivePoolSize()); - - CloseContainerCommandHandler closeContainerCommandHandler = - new CloseContainerCommandHandler(10, 10, ""); - closeContainerCommandHandler.handle(new CloseContainerCommand( - CONTAINER_ID + 1, PipelineID.randomId()), - ozoneContainer, context, null); - closeContainerCommandHandler.handle(new CloseContainerCommand( - CONTAINER_ID + 2, PipelineID.randomId()), - ozoneContainer, context, null); - closeContainerCommandHandler.handle(new CloseContainerCommand( - CONTAINER_ID + 3, PipelineID.randomId()), - ozoneContainer, context, null); - closeContainerCommandHandler.handle(new CloseContainerCommand( - CONTAINER_ID + 4, PipelineID.randomId()), - ozoneContainer, context, null); - assertEquals(10, closeContainerCommandHandler.getThreadPoolMaxPoolSize()); - assertTrue(closeContainerCommandHandler.getThreadPoolActivePoolSize() > 0); } }