This is an automated email from the ASF dual-hosted git repository.
bdeggleston pushed a commit to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cep-45-mutation-tracking by
this push:
new 6ec51ba3f6 ninja - fix TrackedZeroCopyRepairTransferTest &
TrackedNonZeroCopyRepairTransferTest
6ec51ba3f6 is described below
commit 6ec51ba3f624dfb793c72183302ea3e151864ff9
Author: Blake Eggleston <[email protected]>
AuthorDate: Wed Nov 4 22:21:07 2026 -0800
ninja - fix TrackedZeroCopyRepairTransferTest &
TrackedNonZeroCopyRepairTransferTest
---
.../TrackedRepairTransferSuccessTestBase.java | 40 +++++++++++-----------
1 file changed, 20 insertions(+), 20 deletions(-)
diff --git
a/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedRepairTransferSuccessTestBase.java
b/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedRepairTransferSuccessTestBase.java
index 81413325ee..7ea9746cd2 100644
---
a/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedRepairTransferSuccessTestBase.java
+++
b/test/distributed/org/apache/cassandra/distributed/test/tracking/TrackedRepairTransferSuccessTestBase.java
@@ -40,139 +40,139 @@ public abstract class
TrackedRepairTransferSuccessTestBase extends TrackedRepair
public void testFullRepairShardAlignedSinglePlan() throws IOException
{
String keyspace = "full_repair_shard_aligned_single_plan";
- testFullRepairSinglePlan(keyspace, cluster, KEY_200, 2, false,
"repair", "--start-token", SHARD_ALIGNED_RANGE_2.left.toString(),
"--end-token", SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairSinglePlan(keyspace, cluster, KEY_200, 2, false,
"repair", "--skip-sync", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsSinglePlan() throws IOException
{
String keyspace = "full_repair_single_plan";
- testFullRepairSinglePlan(keyspace, cluster, KEY_200, 2, false,
"repair", "--full", keyspace);
+ testFullRepairSinglePlan(keyspace, cluster, KEY_200, 2, false,
"repair", "--skip-sync", "--full", keyspace);
}
@Test
public void testFullRepairShardAlignedSinglePlanOptimized() throws
IOException
{
String keyspace = "full_repair_shard_aligned_single_plan_optimized";
- testFullRepairSinglePlan(keyspace, cluster, KEY_200, 3, true,
"repair", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairSinglePlan(keyspace, cluster, KEY_200, 3, true,
"repair", "--skip-sync", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsSinglePlanOptimized() throws
IOException
{
String keyspace = "full_repair_single_plan_optimized";
- testFullRepairSinglePlan(keyspace, cluster, KEY_200, 3, true,
"repair", "--optimise-streams", "--full", keyspace);
+ testFullRepairSinglePlan(keyspace, cluster, KEY_200, 3, true,
"repair", "--skip-sync", "--optimise-streams", "--full", keyspace);
}
@Test
public void testFullRepairShardAlignedRemoteSender() throws IOException
{
String keyspace = "full_repair_shard_aligned_remote_sender";
- testFullRepairRemoteSender(keyspace, cluster, 2, false, "repair",
"--start-token", SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairRemoteSender(keyspace, cluster, 2, false, "repair",
"--skip-sync", "--start-token", SHARD_ALIGNED_RANGE_2.left.toString(),
"--end-token", SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsRemoteSender() throws IOException
{
String keyspace = "full_repair_remote_sender";
- testFullRepairRemoteSender(keyspace, cluster, 2, false, "repair",
"--full", keyspace);
+ testFullRepairRemoteSender(keyspace, cluster, 2, false, "repair",
"--skip-sync", "--full", keyspace);
}
@Test
public void testFullRepairShardAlignedRemoteSenderOptimized() throws
IOException
{
String keyspace = "full_repair_aligned_optimized_remote_sender";
- testFullRepairRemoteSender(keyspace, cluster, 3, true, "repair",
"--optimise-streams", "--start-token", SHARD_ALIGNED_RANGE_2.left.toString(),
"--end-token", SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairRemoteSender(keyspace, cluster, 3, true, "repair",
"--skip-sync", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsRemoteSenderOptimized() throws
IOException
{
String keyspace = "full_repair_optimized_remote_sender";
- testFullRepairRemoteSender(keyspace, cluster, 3, true, "repair",
"--optimise-streams", "--full", keyspace);
+ testFullRepairRemoteSender(keyspace, cluster, 3, true, "repair",
"--skip-sync", "--optimise-streams", "--full", keyspace);
}
@Test
public void testFullRepairShardAlignedDuplicateSender() throws IOException
{
String keyspace = "full_repair_shard_aligned_duplicate_sender";
- testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 3, false,
"repair", "--start-token", SHARD_ALIGNED_RANGE_1.left.toString(),
"--end-token", SHARD_ALIGNED_RANGE_1.right.toString(), "--full", keyspace);
+ testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 3, false,
"repair", "--skip-sync", "--start-token",
SHARD_ALIGNED_RANGE_1.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_1.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsDuplicateSender() throws IOException
{
String keyspace = "full_repair_duplicate_sender";
- testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 3, false,
"repair", "--full", keyspace);
+ testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 3, false,
"repair", "--skip-sync", "--full", keyspace);
}
@Test
public void testFullRepairShardAlignedDuplicateSenderOptimized() throws
IOException
{
String keyspace = "full_repair_optimized_aligned_duplicate_sender";
- testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 6, true,
"repair", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_1.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_1.right.toString(), "--full", keyspace);
+ testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 6, true,
"repair", "--skip-sync", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_1.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_1.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsDuplicateSenderOptimized() throws
IOException
{
String keyspace = "full_repair_optimized_duplicate_sender";
- testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 6, true,
"repair", "--optimise-streams", "--full", keyspace);
+ testFullRepairDuplicateSender(keyspace, cluster, KEY_100, 6, true,
"repair", "--skip-sync", "--optimise-streams", "--full", keyspace);
}
@Test
public void testFullRepairShardAlignedMultiSender() throws IOException
{
String keyspace = "full_repair_shard_aligned_multi_sender";
- testFullRepairMultiSender(keyspace, cluster, 3, false, "repair",
"--start-token", SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairMultiSender(keyspace, cluster, 3, false, "repair",
"--skip-sync", "--start-token", SHARD_ALIGNED_RANGE_2.left.toString(),
"--end-token", SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsMultiSender() throws IOException
{
String keyspace = "full_repair_multi_sender";
- testFullRepairMultiSender(keyspace, cluster, 3, false, "repair",
"--full", keyspace);
+ testFullRepairMultiSender(keyspace, cluster, 3, false, "repair",
"--skip-sync", "--full", keyspace);
}
@Test
public void testFullRepairShardAlignedMultiSenderOptimized() throws
IOException
{
String keyspace = "full_repair_aligned_optimized_multi_sender";
- testFullRepairMultiSender(keyspace, cluster, 6, true, "repair",
"--optimise-streams", "--start-token", SHARD_ALIGNED_RANGE_2.left.toString(),
"--end-token", SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairMultiSender(keyspace, cluster, 6, true, "repair",
"--skip-sync", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairAcrossShardsMultiSenderOptimized() throws
IOException
{
String keyspace = "full_repair_optimized_multi_sender";
- testFullRepairMultiSender(keyspace, cluster, 6, true, "repair",
"--optimise-streams", "--full", keyspace);
+ testFullRepairMultiSender(keyspace, cluster, 6, true, "repair",
"--skip-sync", "--optimise-streams", "--full", keyspace);
}
@Test
public void testFullRepairMultiSenderSameTokenShardAligned() throws
IOException
{
String keyspace = "full_repair_multi_sender_same_token_aligned";
- testFullRepairMultiSenderSameToken(keyspace, cluster, 3, false,
"repair", "--start-token", SHARD_ALIGNED_RANGE_2.left.toString(),
"--end-token", SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairMultiSenderSameToken(keyspace, cluster, 3, false,
"repair", "--skip-sync", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairMultiSenderSameTokenAcrossShards() throws
IOException
{
String keyspace = "full_repair_multi_sender_same_token";
- testFullRepairMultiSenderSameToken(keyspace, cluster, 3, false,
"repair", "--full", keyspace);
+ testFullRepairMultiSenderSameToken(keyspace, cluster, 3, false,
"repair", "--skip-sync", "--full", keyspace);
}
@Test
public void testFullRepairMultiSenderSameTokenShardAlignedOptimized()
throws IOException
{
String keyspace = "full_multi_sender_same_token_aligned_optimized";
- testFullRepairMultiSenderSameToken(keyspace, cluster, 6, true,
"repair", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
+ testFullRepairMultiSenderSameToken(keyspace, cluster, 6, true,
"repair", "--skip-sync", "--optimise-streams", "--start-token",
SHARD_ALIGNED_RANGE_2.left.toString(), "--end-token",
SHARD_ALIGNED_RANGE_2.right.toString(), "--full", keyspace);
}
@Test
public void testFullRepairMultiSenderSameTokenAcrossShardsOptimized()
throws IOException
{
String keyspace = "full_multi_sender_same_token_optimized";
- testFullRepairMultiSenderSameToken(keyspace, cluster, 6, true,
"repair", "--optimise-streams", "--full", keyspace);
+ testFullRepairMultiSenderSameToken(keyspace, cluster, 6, true,
"repair", "--skip-sync", "--optimise-streams", "--full", keyspace);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
