This is an automated email from the ASF dual-hosted git repository.

jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new 244c947fdd Fix flaky PinotTenantRestletResourceTest (#12026)
244c947fdd is described below

commit 244c947fdd90f194ed0b7b3b12a86d7805a34675
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Fri Nov 17 15:27:22 2023 -0800

    Fix flaky PinotTenantRestletResourceTest (#12026)
---
 .../apache/pinot/controller/api/PinotTenantRestletResourceTest.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/pinot-controller/src/test/java/org/apache/pinot/controller/api/PinotTenantRestletResourceTest.java
 
b/pinot-controller/src/test/java/org/apache/pinot/controller/api/PinotTenantRestletResourceTest.java
index b986842a74..34c06f73a8 100644
--- 
a/pinot-controller/src/test/java/org/apache/pinot/controller/api/PinotTenantRestletResourceTest.java
+++ 
b/pinot-controller/src/test/java/org/apache/pinot/controller/api/PinotTenantRestletResourceTest.java
@@ -129,10 +129,14 @@ public class PinotTenantRestletResourceTest extends 
ControllerTest {
     assertEquals(tables.get(0).asText(), offlineTableName2);
 
     // Remove the tables and brokers
+    DEFAULT_INSTANCE.waitForEVToAppear(OFFLINE_TABLE_NAME);
+    DEFAULT_INSTANCE.waitForEVToAppear(offlineTableName2);
     DEFAULT_INSTANCE.dropOfflineTable(RAW_TABLE_NAME);
     DEFAULT_INSTANCE.deleteSchema(RAW_TABLE_NAME);
     DEFAULT_INSTANCE.dropOfflineTable(rawTableName2);
     DEFAULT_INSTANCE.deleteSchema(rawTableName2);
+    DEFAULT_INSTANCE.waitForEVToDisappear(OFFLINE_TABLE_NAME);
+    DEFAULT_INSTANCE.waitForEVToDisappear(offlineTableName2);
     sendDeleteRequest(_urlBuilder.forInstance("Broker_1.2.3.4_1234"));
     sendDeleteRequest(_urlBuilder.forInstance("Broker_2.3.4.5_2345"));
   }
@@ -210,6 +214,7 @@ public class PinotTenantRestletResourceTest extends 
ControllerTest {
     // Delete table and schema
     DEFAULT_INSTANCE.dropOfflineTable(RAW_TABLE_NAME);
     DEFAULT_INSTANCE.deleteSchema(RAW_TABLE_NAME);
+    DEFAULT_INSTANCE.waitForEVToDisappear(OFFLINE_TABLE_NAME);
   }
 
   @AfterClass


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to