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

fix

This commit is contained in:
Alan Wang 2026-07-30 16:16:28 -07:00
parent 964f88a7ef
commit 1d9bf679e3
1 changed files with 0 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -58,7 +58,6 @@ import org.apache.cassandra.service.accord.LocalTransfers;
import org.apache.cassandra.utils.Shared;
import org.assertj.core.api.Assertions;
import org.junit.Ignore;
import org.junit.Test;
import static com.google.common.collect.Iterables.getOnlyElement;
@ -71,7 +70,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class AccordImportSSTableTest extends TestBaseImpl
{
private static final String TABLE = "tbl";
private static final String KEYSPACE_TABLE = String.format("%s.%s", KEYSPACE, TABLE);
private static final String TABLE_SCHEMA_CQL = String.format(withKeyspace("CREATE TABLE %s." + TABLE + " (k int primary key, v int);"));
@ -194,40 +192,6 @@ public class AccordImportSSTableTest extends TestBaseImpl
}
}
@Test
@Ignore
public void testSSTableImportReplicaDown() throws Throwable
{
String file = writeSSTables(new int[] { 1, 2, 3 });
int FAILED_REPLICA = 2;
try (Cluster cluster = init(builder().withNodes(3).withoutVNodes()
.withDataDirCount(1).withConfig((config) ->
config.with(Feature.NETWORK, Feature.GOSSIP)).start()))
{
createSchema(cluster);
cluster.get(FAILED_REPLICA).shutdown().get();
cluster.get(1).runOnInstance(() -> {
ColumnFamilyStore cfs = ColumnFamilyStore.getIfExists(KEYSPACE, TABLE);
Set<String> paths = Set.of(file);
Assertions.assertThatThrownBy(() -> cfs.importNewSSTables(paths, true, true, true, true, true, true, true))
.isInstanceOf(RuntimeException.class);
});
Iterable<IInvokableInstance> up = cluster.stream()
.filter(instance -> instance != cluster.get(FAILED_REPLICA))
.collect(Collectors.toList());
assertPendingDirs(up, (File pendingUuidDir) -> {
Assertions.assertThat(pendingUuidDir.listUnchecked(File::isFile)).isEmpty();
});
assertLocalSelect(up, rows -> assertRows(rows, EMPTY_ROWS));
}
}
@Test
public void testSSTableImportStreamingFailedCleanup() throws Throwable
{