You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ma...@apache.org on 2020/12/02 12:19:22 UTC
[cassandra] branch trunk updated: CASSANDRA-16274 followup 2 -
reduce iterations in OptimiseStreamsRepairTest to make it pass in low
resource CI
This is an automated email from the ASF dual-hosted git repository.
marcuse pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/trunk by this push:
new 90b2f3e CASSANDRA-16274 followup 2 - reduce iterations in OptimiseStreamsRepairTest to make it pass in low resource CI
90b2f3e is described below
commit 90b2f3e068a95e4fd70ec19d0dff60abcf10efc8
Author: Marcus Eriksson <ma...@apache.org>
AuthorDate: Wed Dec 2 13:18:04 2020 +0100
CASSANDRA-16274 followup 2 - reduce iterations in OptimiseStreamsRepairTest to make it pass in low resource CI
---
.../cassandra/distributed/test/OptimiseStreamsRepairTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/test/distributed/org/apache/cassandra/distributed/test/OptimiseStreamsRepairTest.java b/test/distributed/org/apache/cassandra/distributed/test/OptimiseStreamsRepairTest.java
index 8a1c1d7..96ae1dc 100644
--- a/test/distributed/org/apache/cassandra/distributed/test/OptimiseStreamsRepairTest.java
+++ b/test/distributed/org/apache/cassandra/distributed/test/OptimiseStreamsRepairTest.java
@@ -72,7 +72,7 @@ public class OptimiseStreamsRepairTest extends TestBaseImpl
.start()))
{
cluster.schemaChange("create table " + KEYSPACE + ".tbl (id int primary key, t int) with compaction={'class': 'SizeTieredCompactionStrategy'}");
- for (int i = 0; i < 100000; i++)
+ for (int i = 0; i < 10000; i++)
cluster.coordinator(1).execute("INSERT INTO " + KEYSPACE + ".tbl (id, t) values (?,?)", ConsistencyLevel.ALL, i, i);
cluster.forEach((i) -> i.flush(KEYSPACE));
@@ -82,7 +82,7 @@ public class OptimiseStreamsRepairTest extends TestBaseImpl
cluster.coordinator(1).execute("INSERT INTO "+KEYSPACE+".tbl (id, t) values (?,?)", ConsistencyLevel.QUORUM, i, i * 2 + 2);
cluster.get(2).startup();
- Thread.sleep(10000);
+ Thread.sleep(1000);
cluster.forEach(c -> c.flush(KEYSPACE));
cluster.forEach(c -> c.forceCompact(KEYSPACE, "tbl"));
@@ -171,12 +171,12 @@ public class OptimiseStreamsRepairTest extends TestBaseImpl
.start()))
{
cluster.schemaChange("create table " + KEYSPACE + ".tbl (id int primary key, t int) with compaction={'class': 'SizeTieredCompactionStrategy'}");
- for (int i = 0; i < 10_000; i++)
+ for (int i = 0; i < 1000; i++)
cluster.coordinator(1).execute("INSERT INTO " + KEYSPACE + ".tbl (id, t) values (?,?)", ConsistencyLevel.ALL, i, i);
cluster.forEach((i) -> i.flush(KEYSPACE));
Random r = new Random();
- for (int i = 0; i < 20000; i++)
+ for (int i = 0; i < 500; i++)
for (int j = 1; j <= 3; j++)
cluster.get(j).executeInternal("INSERT INTO "+KEYSPACE+".tbl (id, t) values (?,?)", r.nextInt(), i * 2 + 2);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org