cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject git commit: Make default stress batches logged
Date Fri, 01 Aug 2014 13:32:41 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.1.0 d667556d0 -> 1921b9859


Make default stress batches logged


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/1921b985
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1921b985
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1921b985

Branch: refs/heads/cassandra-2.1.0
Commit: 1921b98599aa5190c74737c4e8a1092c63f842dc
Parents: d667556
Author: Jake Luciani <jake@apache.org>
Authored: Fri Aug 1 09:32:31 2014 -0400
Committer: Jake Luciani <jake@apache.org>
Committed: Fri Aug 1 09:32:31 2014 -0400

----------------------------------------------------------------------
 tools/stress/src/org/apache/cassandra/stress/StressProfile.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/1921b985/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
----------------------------------------------------------------------
diff --git a/tools/stress/src/org/apache/cassandra/stress/StressProfile.java b/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
index f24ec8c..4e09775 100644
--- a/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
+++ b/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
@@ -331,7 +331,7 @@ public class StressProfile implements Serializable
                     partitions = OptionDistribution.get(!insert.containsKey("partitions")
? "fixed(1)" : insert.remove("partitions"));
                     pervisit = OptionRatioDistribution.get(!insert.containsKey("pervisit")
? "fixed(1)/1" : insert.remove("pervisit"));
                     perbatch = OptionRatioDistribution.get(!insert.containsKey("perbatch")
? "fixed(1)/1" : insert.remove("perbatch"));
-                    batchType = !insert.containsKey("batchtype") ? BatchStatement.Type.UNLOGGED
: BatchStatement.Type.valueOf(insert.remove("batchtype"));
+                    batchType = !insert.containsKey("batchtype") ? BatchStatement.Type.LOGGED
: BatchStatement.Type.valueOf(insert.remove("batchtype"));
                     if (!insert.isEmpty())
                         throw new IllegalArgumentException("Unrecognised insert option(s):
" + insert);
 


Mime
View raw message