From e3c1d8b0c968d0e792fd02f640b28f693e884aa1 Mon Sep 17 00:00:00 2001 From: Roy Dahan Date: Wed, 29 Nov 2023 20:00:30 +0200 Subject: [PATCH] cassandra-stress: switch create table to use keyspace.table format Stop using "Use keyspace" since it can fail when using multiple stress commands in parallel due to a race condition. fixes: #356 --- .../apache/cassandra/stress/settings/SettingsSchema.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/tools/stress/src/org/apache/cassandra/stress/settings/SettingsSchema.java b/tools/stress/src/org/apache/cassandra/stress/settings/SettingsSchema.java index 57260720ab..0b4442e34a 100644 --- a/tools/stress/src/org/apache/cassandra/stress/settings/SettingsSchema.java +++ b/tools/stress/src/org/apache/cassandra/stress/settings/SettingsSchema.java @@ -87,9 +87,7 @@ public void createKeySpacesNative(StressSettings settings) { //Keyspace client.execute(createKeyspaceStatementCQL3(), org.apache.cassandra.db.ConsistencyLevel.LOCAL_ONE); - - client.execute("USE \""+keyspace+"\"", org.apache.cassandra.db.ConsistencyLevel.LOCAL_ONE); - + //Add standard1 client.execute(createStandard1StatementCQL3(settings), org.apache.cassandra.db.ConsistencyLevel.LOCAL_ONE); @@ -152,7 +150,7 @@ String createStandard1StatementCQL3(StressSettings settings) StringBuilder b = new StringBuilder(); b.append("CREATE TABLE IF NOT EXISTS ") - .append("standard1 (key blob PRIMARY KEY "); + .append("\""+keyspace+"\"".standard1 (key blob PRIMARY KEY "); try {