diff --git a/CHANGES.txt b/CHANGES.txt index 112355312a..bdb6e2987c 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.10 + * Fix cassandra-stress truncate option (CASSANDRA-12695) * Fix crossNode value when receiving messages (CASSANDRA-12791) * Don't load MX4J beans twice (CASSANDRA-12869) * Extend native protocol request flags, add versions to SUPPORTED, and introduce ProtocolVersion enum (CASSANDRA-12838) diff --git a/tools/stress/src/org/apache/cassandra/stress/StressAction.java b/tools/stress/src/org/apache/cassandra/stress/StressAction.java index eaee752318..30f8899efc 100644 --- a/tools/stress/src/org/apache/cassandra/stress/StressAction.java +++ b/tools/stress/src/org/apache/cassandra/stress/StressAction.java @@ -62,7 +62,8 @@ public class StressAction implements Runnable if (!settings.command.noWarmup) warmup(settings.command.getFactory(settings)); - if (settings.command.truncate == SettingsCommand.TruncateWhen.ONCE) + if ((settings.command.truncate == SettingsCommand.TruncateWhen.ONCE) || + ((settings.rate.threadCount != -1) && (settings.command.truncate == SettingsCommand.TruncateWhen.ALWAYS))) settings.command.truncateTables(settings); // Required for creating a graph from the output file