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

dtest for compaction though mock

This commit is contained in:
Maxim Muzafarov 2026-07-11 12:26:40 +02:00
parent 4989f7f3b8
commit 903a2b2443
No known key found for this signature in database
GPG Key ID: 7FEC714D84388C16
2 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
test/distributed/org/apache/cassandra/distributed/mock/nodetool/InternalNodeProbe.java
View File

@ -34,6 +34,7 @@ import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.ColumnFamilyStoreMBean;
import org.apache.cassandra.db.Keyspace;
import org.apache.cassandra.db.compaction.CompactionManager;
import org.apache.cassandra.db.compaction.CompactionManagerMBean;
import org.apache.cassandra.db.compression.CompressionDictionaryManagerMBean;
import org.apache.cassandra.gms.FailureDetector;
import org.apache.cassandra.gms.FailureDetectorMBean;
@ -187,7 +188,7 @@ public class InternalNodeProbe extends NodeProbe
registerMBean(AccordOperationsMBean.class, AccordOperations.instance);
registerMBean(MessagingServiceMBean.class, MessagingService.instance());
registerMBean(StreamManagerMBean.class, StreamManager.instance);
registerMBean(CompactionManager.class, CompactionManager.instance);
registerMBean(CompactionManagerMBean.class, CompactionManager.instance);
registerMBean(FailureDetectorMBean.class, (FailureDetectorMBean) FailureDetector.instance);
registerMBean(CacheServiceMBean.class, CacheService.instance);
registerMBean(StorageProxyMBean.class, StorageProxy.instance);

19
test/distributed/org/apache/cassandra/distributed/test/NodeToolTest.java
View File

@ -27,6 +27,7 @@ import org.junit.Test;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.distributed.Cluster;
import org.apache.cassandra.distributed.api.ConsistencyLevel;
import org.apache.cassandra.distributed.api.ICluster;
import org.apache.cassandra.distributed.api.IInvokableInstance;
import org.apache.cassandra.distributed.api.NodeToolResult;
@ -141,6 +142,24 @@ public class NodeToolTest extends TestBaseImpl
}
}
@Test
public void testCompactionCommandsThroughMockProbe()
{
String table = "compaction_history_tbl";
CLUSTER.schemaChange("CREATE TABLE " + KEYSPACE + '.' + table + " (k int PRIMARY KEY, v int)");
assertEquals(0, NODE.nodetool("disableautocompaction", KEYSPACE));
for (int i = 0; i < 2; i++)
{
CLUSTER.coordinator(1).execute("INSERT INTO " + KEYSPACE + '.' + table + " (k, v) VALUES (?, ?)",
ConsistencyLevel.ONE, i, i);
NODE.flush(KEYSPACE);
}
NODE.forceCompact(KEYSPACE, table);
NODE.nodetoolResult("compactionhistory").asserts().success().stdoutContains(table);
NODE.nodetoolResult("stop", "COMPACTION").asserts().success();
}
@Test
public void testVersionIncludesGitSHAWhenVerbose() throws Throwable
{