You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ne...@apache.org on 2021/11/22 18:40:23 UTC

[pinot] branch master updated: allow to override how to wait for quick start to finish bootstrap (#7808)

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

nehapawar 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 a83060c  allow to override how to wait for quick start to finish bootstrap (#7808)
a83060c is described below

commit a83060c700e61510d51d9d7496ca55672bb39cec
Author: Xiaobing <61...@users.noreply.github.com>
AuthorDate: Mon Nov 22 10:40:06 2021 -0800

    allow to override how to wait for quick start to finish bootstrap (#7808)
    
    Co-authored-by: Xiaobing Li <xi...@startree.ai>
---
 pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java b/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java
index 1879815..25c5985 100644
--- a/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java
+++ b/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java
@@ -67,6 +67,12 @@ public class Quickstart extends QuickStartBase {
     return null;
   }
 
+  protected void waitForBootstrapToComplete(QuickstartRunner runner)
+      throws Exception {
+    printStatus(Color.CYAN, "***** Waiting for 5 seconds for the server to fetch the assigned segment *****");
+    Thread.sleep(5000);
+  }
+
   public static void printStatus(Color color, String message) {
     System.out.println(color._code + message + Color.RESET._code);
   }
@@ -201,8 +207,7 @@ public class Quickstart extends QuickStartBase {
     printStatus(Color.CYAN, "***** Bootstrap baseballStats table *****");
     runner.bootstrapTable();
 
-    printStatus(Color.CYAN, "***** Waiting for 5 seconds for the server to fetch the assigned segment *****");
-    Thread.sleep(5000);
+    waitForBootstrapToComplete(runner);
 
     printStatus(Color.YELLOW, "***** Offline quickstart setup complete *****");
 

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org