missed to delete the temp dir (apache#12637)

soumitra-st · Mar 13, 2024 · 394922e · 394922e
1 parent e1aee5f
commit 394922e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/...t-integration-test-base/src/test/java/org/apache/pinot/integration/tests/ClusterTest.java b/...t-integration-test-base/src/test/java/org/apache/pinot/integration/tests/ClusterTest.java
@@ -346,7 +346,7 @@ protected void stopServer() {
     for (BaseServerStarter serverStarter : _serverStarters) {
       serverStarter.stop();
     }
-    FileUtils.deleteQuietly(new File(_baseInstanceDataDir + File.separator + "PinotServer"));
+    FileUtils.deleteQuietly(new File(_baseInstanceDataDir));
     _serverStarters = null;
     _serverGrpcPort = 0;
     _serverAdminApiPort = 0;

diff --git a/...t/java/org/apache/pinot/integration/tests/PartialUpsertTableRebalanceIntegrationTest.java b/...t/java/org/apache/pinot/integration/tests/PartialUpsertTableRebalanceIntegrationTest.java
@@ -28,6 +28,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import org.apache.commons.io.FileUtils;
 import org.apache.helix.model.IdealState;
 import org.apache.pinot.client.ResultSetGroup;
 import org.apache.pinot.common.exception.HttpErrorStatusException;
@@ -299,12 +300,14 @@ protected void createSchemaAndTable()
   }
 
   @AfterClass
-  public void tearDown() {
+  public void tearDown()
+      throws IOException {
     stopServer();
     stopBroker();
     stopController();
     stopKafka();
     stopZk();
+    FileUtils.deleteDirectory(_tempDir);
   }
 
   @Override