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 2e1e0eafd01..1251a33072f 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); } }