natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

update for test

This commit is contained in:
Alan Wang 2026-07-17 12:14:42 -07:00
parent c8079bd97f
commit 675c4a87e5
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/java/org/apache/cassandra/service/accord/AccordService.java
View File

@ -1449,7 +1449,7 @@ public class AccordService implements IAccordService, Shutdownable
Preconditions.checkArgument(!nodeStreamingContext.isEmpty());
CoordinatedTransfer transfer = new CoordinatedTransfer(node().nextCoordinationId(), keyspace, metadata, nodeStreamingContext, topology.epoch(), getTokenRangeSpanningSSTables(sstables, metadata));
CoordinatedTransfer transfer = new CoordinatedTransfer(node().nextCoordinatedTransferId(), keyspace, metadata, nodeStreamingContext, topology.epoch(), getTokenRangeSpanningSSTables(sstables, metadata));
transfer.execute();
}

2
test/distributed/org/apache/cassandra/distributed/test/accord/AccordImportSSTableTest.java
View File

@ -346,6 +346,8 @@ public class AccordImportSSTableTest extends TestBaseImpl
try (Cluster cluster = init(builder().withNodes(3).withoutVNodes()
.withDataDirCount(1).withConfig((config) ->
config
.set("accord.recover_txn", "100ms")
.set("accord.permit_local_delivery", false)
.with(Feature.NETWORK, Feature.GOSSIP)).start()))
{
cluster.schemaChange("DROP KEYSPACE IF EXISTS " + KEYSPACE);