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 7b71babb73 reformat ClusterTest.java (#12531)
7b71babb73 is described below
commit 7b71babb73bede74508fab5de688f6743c18c346
Author: sullis <[email protected]>
AuthorDate: Fri Mar 1 16:10:35 2024 -0800
reformat ClusterTest.java (#12531)
---
.../org/apache/pinot/integration/tests/ClusterTest.java | 16 ++++------------
1 file changed, 4 insertions(+), 12 deletions(-)
diff --git
a/pinot-integration-test-base/src/test/java/org/apache/pinot/integration/tests/ClusterTest.java
b/pinot-integration-test-base/src/test/java/org/apache/pinot/integration/tests/ClusterTest.java
index 7a9cf0a860..d2bfba1c5e 100644
---
a/pinot-integration-test-base/src/test/java/org/apache/pinot/integration/tests/ClusterTest.java
+++
b/pinot-integration-test-base/src/test/java/org/apache/pinot/integration/tests/ClusterTest.java
@@ -178,11 +178,7 @@ public abstract class ClusterTest extends ControllerTest {
_brokerPorts = new ArrayList<>();
for (int i = 0; i < numBrokers; i++) {
BaseBrokerStarter brokerStarter = startOneBroker(i);
- assertEquals(
- brokerStarter.getConfig().getProperty(
- CommonConstants.CONFIG_OF_TIMEZONE, ""),
- "UTC"
- );
+
assertEquals(brokerStarter.getConfig().getProperty(CommonConstants.CONFIG_OF_TIMEZONE,
""), "UTC");
assertEquals(System.getProperty("user.timezone"), "UTC");
_brokerStarters.add(brokerStarter);
@@ -256,8 +252,7 @@ public abstract class ClusterTest extends ControllerTest {
serverConf.setProperty(Server.CONFIG_OF_ADMIN_API_PORT,
_serverAdminApiPort);
_serverNettyPort = NetUtils.findOpenPort(Helix.DEFAULT_SERVER_NETTY_PORT +
new Random().nextInt(10000) + serverId);
serverConf.setProperty(Helix.KEY_OF_SERVER_NETTY_PORT, _serverNettyPort);
- _serverGrpcPort =
- NetUtils.findOpenPort(Server.DEFAULT_GRPC_PORT + new
Random().nextInt(10000) + serverId);
+ _serverGrpcPort = NetUtils.findOpenPort(Server.DEFAULT_GRPC_PORT + new
Random().nextInt(10000) + serverId);
serverConf.setProperty(Server.CONFIG_OF_GRPC_PORT, _serverGrpcPort);
// Thread time measurement is disabled by default, enable it in
integration tests.
@@ -622,17 +617,14 @@ public abstract class ClusterTest extends ControllerTest {
@DataProvider(name = "systemColumns")
public Object[][] systemColumns() {
return new Object[][]{
- {"$docId"},
- {"$hostName"},
- {"$segmentName"}
+ {"$docId"}, {"$hostName"}, {"$segmentName"}
};
}
@DataProvider(name = "useBothQueryEngines")
public Object[][] useBothQueryEngines() {
return new Object[][]{
- {false},
- {true}
+ {false}, {true}
};
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
