This is an automated email from the ASF dual-hosted git repository.
ifesdjeen pushed a commit to branch cep-15-accord
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cep-15-accord by this push:
new 60b5a65849 Remove duplicate bounce from load test
60b5a65849 is described below
commit 60b5a65849b9f17f8309aef5fe154e9258bdce00
Author: Alex Petrov <[email protected]>
AuthorDate: Tue Oct 15 16:03:36 2024 +0200
Remove duplicate bounce from load test
---
.../cassandra/distributed/test/accord/AccordLoadTest.java | 12 ------------
1 file changed, 12 deletions(-)
diff --git
a/test/distributed/org/apache/cassandra/distributed/test/accord/AccordLoadTest.java
b/test/distributed/org/apache/cassandra/distributed/test/accord/AccordLoadTest.java
index a299abd713..8f2dabe624 100644
---
a/test/distributed/org/apache/cassandra/distributed/test/accord/AccordLoadTest.java
+++
b/test/distributed/org/apache/cassandra/distributed/test/accord/AccordLoadTest.java
@@ -47,7 +47,6 @@ import org.apache.cassandra.distributed.api.Feature;
import org.apache.cassandra.distributed.api.ICoordinator;
import org.apache.cassandra.distributed.api.IMessage;
import org.apache.cassandra.distributed.api.IMessageFilters;
-import org.apache.cassandra.distributed.shared.ClusterUtils;
import org.apache.cassandra.distributed.shared.DistributedTestBase;
import org.apache.cassandra.net.Verb;
import org.apache.cassandra.service.accord.AccordService;
@@ -98,7 +97,6 @@ public class AccordLoadTest extends AccordTestBase
ICoordinator coordinator = cluster.coordinator(1);
final int repairInterval = Integer.MAX_VALUE;
- final int bounceInterval = 3000;
// final int repairInterval = 3000;
// final int compactionInterval = Integer.MAX_VALUE;
final int compactionInterval = 3000;
@@ -112,7 +110,6 @@ public class AccordLoadTest extends AccordTestBase
final int ratePerSecond = 1000;
final int keyCount = 1_000_000;
final float readChance = 0.33f;
- long nextBounce = bounceInterval;
long nextRepairAt = repairInterval;
long nextCompactionAt = compactionInterval;
long nextFlushAt = flushInterval;
@@ -182,15 +179,6 @@ public class AccordLoadTest extends AccordTestBase
cluster.coordinator(1).instance().nodetool("repair", qualifiedAccordTableName);
}
- if ((nextBounce -= batchSize) <= 0)
- {
- nextBounce += bounceInterval;
- System.out.println("bouncing...");
- cluster.get(2).nodetool("drain");
- ClusterUtils.stopUnchecked(cluster.get(2));
- cluster.get(2).startup();
- }
-
if ((nextCompactionAt -= batchSize) <= 0)
{
nextCompactionAt += compactionInterval;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
