You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2021/10/01 22:58:03 UTC
[pinot] branch master updated: remove unnecessary wait during
broker test (#7505)
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 76023ae remove unnecessary wait during broker test (#7505)
76023ae is described below
commit 76023ae15d47124236997bef53741ea7e19d436c
Author: Rong Rong <wa...@gmail.com>
AuthorDate: Fri Oct 1 15:57:49 2021 -0700
remove unnecessary wait during broker test (#7505)
---
.../apache/pinot/broker/broker/HelixBrokerStarterHostnamePortTest.java | 3 +++
.../java/org/apache/pinot/broker/broker/HelixBrokerStarterTest.java | 2 ++
2 files changed, 5 insertions(+)
diff --git a/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterHostnamePortTest.java b/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterHostnamePortTest.java
index 6821a02..0d0e5d0 100644
--- a/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterHostnamePortTest.java
+++ b/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterHostnamePortTest.java
@@ -30,6 +30,7 @@ import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
import static org.apache.pinot.spi.utils.CommonConstants.Broker.CONFIG_OF_BROKER_HOSTNAME;
+import static org.apache.pinot.spi.utils.CommonConstants.Broker.CONFIG_OF_DELAY_SHUTDOWN_TIME_MS;
import static org.apache.pinot.spi.utils.CommonConstants.Helix.CONFIG_OF_CLUSTER_NAME;
import static org.apache.pinot.spi.utils.CommonConstants.Helix.CONFIG_OF_ZOOKEEPR_SERVER;
import static org.apache.pinot.spi.utils.CommonConstants.Helix.Instance.INSTANCE_ID_KEY;
@@ -55,6 +56,7 @@ public class HelixBrokerStarterHostnamePortTest extends ControllerTest {
properties.put(INSTANCE_ID_KEY, "Broker_myInstance");
properties.put(CONFIG_OF_BROKER_HOSTNAME, "myHost");
properties.put(KEY_OF_BROKER_QUERY_PORT, 1234);
+ properties.put(CONFIG_OF_DELAY_SHUTDOWN_TIME_MS, 0);
HelixBrokerStarter brokerStarter = new HelixBrokerStarter();
brokerStarter.init(new PinotConfiguration(properties));
@@ -92,6 +94,7 @@ public class HelixBrokerStarterHostnamePortTest extends ControllerTest {
properties.put(CONFIG_OF_CLUSTER_NAME, getHelixClusterName());
properties.put(CONFIG_OF_BROKER_HOSTNAME, "myHost");
properties.put(KEY_OF_BROKER_QUERY_PORT, 1234);
+ properties.put(CONFIG_OF_DELAY_SHUTDOWN_TIME_MS, 0);
HelixBrokerStarter brokerStarter = new HelixBrokerStarter();
brokerStarter.init(new PinotConfiguration(properties));
diff --git a/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterTest.java b/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterTest.java
index 6464e46..0366e09 100644
--- a/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterTest.java
+++ b/pinot-broker/src/test/java/org/apache/pinot/broker/broker/HelixBrokerStarterTest.java
@@ -42,6 +42,7 @@ import org.apache.pinot.spi.data.DateTimeGranularitySpec;
import org.apache.pinot.spi.data.FieldSpec;
import org.apache.pinot.spi.data.Schema;
import org.apache.pinot.spi.env.PinotConfiguration;
+import org.apache.pinot.spi.utils.CommonConstants.Broker;
import org.apache.pinot.spi.utils.CommonConstants.Helix;
import org.apache.pinot.spi.utils.builder.TableConfigBuilder;
import org.apache.pinot.spi.utils.builder.TableNameBuilder;
@@ -79,6 +80,7 @@ public class HelixBrokerStarterTest extends ControllerTest {
properties.put(Helix.KEY_OF_BROKER_QUERY_PORT, 18099);
properties.put(Helix.CONFIG_OF_CLUSTER_NAME, getHelixClusterName());
properties.put(Helix.CONFIG_OF_ZOOKEEPR_SERVER, getZkUrl());
+ properties.put(Broker.CONFIG_OF_DELAY_SHUTDOWN_TIME_MS, 0);
_brokerStarter = new HelixBrokerStarter();
_brokerStarter.init(new PinotConfiguration(properties));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org