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 2024/10/18 23:57:54 UTC
(pinot) branch master updated: Reduce the test workload for IdealStateGroupCommitTest considering the CI machine capacity (#14255)
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 ec34ec51b5 Reduce the test workload for IdealStateGroupCommitTest considering the CI machine capacity (#14255)
ec34ec51b5 is described below
commit ec34ec51b558948ab923bf524c4ad6bba58cc020
Author: Xiang Fu <xi...@gmail.com>
AuthorDate: Sat Oct 19 07:57:49 2024 +0800
Reduce the test workload for IdealStateGroupCommitTest considering the CI machine capacity (#14255)
---
.../pinot/controller/helix/IdealStateGroupCommitTest.java | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
diff --git a/pinot-controller/src/test/java/org/apache/pinot/controller/helix/IdealStateGroupCommitTest.java b/pinot-controller/src/test/java/org/apache/pinot/controller/helix/IdealStateGroupCommitTest.java
index 40304d14c6..98c8aa6ef4 100644
--- a/pinot-controller/src/test/java/org/apache/pinot/controller/helix/IdealStateGroupCommitTest.java
+++ b/pinot-controller/src/test/java/org/apache/pinot/controller/helix/IdealStateGroupCommitTest.java
@@ -45,8 +45,11 @@ public class IdealStateGroupCommitTest {
private static final Logger LOGGER = LoggerFactory.getLogger(IdealStateGroupCommitTest.class);
private static final ControllerTest TEST_INSTANCE = ControllerTest.getInstance();
private static final String TABLE_NAME_PREFIX = "potato_";
- private static final int NUM_PROCESSORS = 100;
- private static final int NUM_UPDATES = 2000;
+
+ private static final int SYSTEM_MULTIPLIER = Math.max(1, Runtime.getRuntime().availableProcessors() / 2);
+
+ private static final int NUM_PROCESSORS = 5 * SYSTEM_MULTIPLIER;
+ private static final int NUM_UPDATES = 100 * SYSTEM_MULTIPLIER;
private static final int NUM_TABLES = 20;
private ExecutorService _executorService;
@@ -54,8 +57,9 @@ public class IdealStateGroupCommitTest {
@BeforeClass
public void setUp()
throws Exception {
+ LOGGER.info("Starting IdealStateGroupCommitTest with SYSTEM_MULTIPLIER: {}", SYSTEM_MULTIPLIER);
TEST_INSTANCE.setupSharedStateAndValidate();
- _executorService = Executors.newFixedThreadPool(100);
+ _executorService = Executors.newFixedThreadPool(4);
}
@BeforeMethod
@@ -112,7 +116,7 @@ public class IdealStateGroupCommitTest {
ControllerMetrics controllerMetrics = ControllerMetrics.get();
long idealStateUpdateSuccessCount =
controllerMetrics.getMeteredTableValue(tableName, ControllerMeter.IDEAL_STATE_UPDATE_SUCCESS).count();
- Assert.assertTrue(idealStateUpdateSuccessCount < NUM_UPDATES);
+ Assert.assertTrue(idealStateUpdateSuccessCount <= NUM_UPDATES);
LOGGER.info("{} IdealState update are successfully commited with {} times zk updates.", NUM_UPDATES,
idealStateUpdateSuccessCount);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org