This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 6de9e30c4638d8ac50d4088a65f0c700527b3ba9 Author: Clebert Suconic <[email protected]> AuthorDate: Tue Mar 28 04:33:24 2023 -0400 NO-JIRA Limiting load on NIOJournalCompactTest This test is boundless adding data into the journal when there are no syncs. That's creating 600MIB worth of data on our CIs, and this tests was not meant to be acting like a soak test. I'm limitting the load the test can generate with a TokenBucketLimiterImpl now. --- .../artemis/tests/integration/journal/NIOJournalCompactTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOJournalCompactTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOJournalCompactTest.java index b3c12cc755..9503418ba1 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOJournalCompactTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/journal/NIOJournalCompactTest.java @@ -57,6 +57,8 @@ import org.apache.activemq.artemis.tests.unit.core.journal.impl.fakes.SimpleEnco import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.utils.ActiveMQThreadFactory; import org.apache.activemq.artemis.utils.IDGenerator; +import org.apache.activemq.artemis.utils.TokenBucketLimiter; +import org.apache.activemq.artemis.utils.TokenBucketLimiterImpl; import org.apache.activemq.artemis.utils.actors.OrderedExecutorFactory; import org.apache.activemq.artemis.utils.SimpleIDGenerator; import org.apache.activemq.artemis.utils.critical.EmptyCriticalAnalyzer; @@ -2017,8 +2019,10 @@ public class NIOJournalCompactTest extends JournalImplTestBase { Runnable producerRunnable = new Runnable() { @Override public void run() { + TokenBucketLimiter limiter = new TokenBucketLimiterImpl(5000, true); try { while (running.get()) { + limiter.limit(); final long[] values = new long[100]; long tx = seqGenerator.incrementAndGet(); @@ -2104,7 +2108,7 @@ public class NIOJournalCompactTest extends JournalImplTestBase { Thread compactorThread = new Thread(compressRunnable); compactorThread.start(); - Thread.sleep(1000); + Thread.sleep(500); running.set(false);
