Updated Branches: refs/heads/cassandra-1.2 0934bffa1 -> b49ca58b2
ninja relocate crc_check_chance removal from options list Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b49ca58b Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b49ca58b Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b49ca58b Branch: refs/heads/cassandra-1.2 Commit: b49ca58b2a7fb272e21dd2acd00996483a36ddcc Parents: 0934bff Author: Jake Luciani <jluci...@bluemountaincapital.com> Authored: Fri Dec 7 12:50:49 2012 -0500 Committer: Jake Luciani <jluci...@bluemountaincapital.com> Committed: Fri Dec 7 12:57:33 2012 -0500 ---------------------------------------------------------------------- .../io/compress/CompressionParameters.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b49ca58b/src/java/org/apache/cassandra/io/compress/CompressionParameters.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/io/compress/CompressionParameters.java b/src/java/org/apache/cassandra/io/compress/CompressionParameters.java index df077ac..93e150f 100644 --- a/src/java/org/apache/cassandra/io/compress/CompressionParameters.java +++ b/src/java/org/apache/cassandra/io/compress/CompressionParameters.java @@ -56,7 +56,6 @@ public class CompressionParameters String chunkLength = options.get(CHUNK_LENGTH_KB); options.remove(SSTABLE_COMPRESSION); options.remove(CHUNK_LENGTH_KB); - options.remove(CRC_CHECK_CHANCE); CompressionParameters cp = new CompressionParameters(sstableCompressionClass, parseChunkLength(chunkLength), options); cp.validate(); return cp; @@ -78,6 +77,7 @@ public class CompressionParameters this.chunkLength = chunkLength; this.otherOptions = otherOptions; String chance = otherOptions.get(CRC_CHECK_CHANCE); + otherOptions.remove(CRC_CHECK_CHANCE); this.crcChance = (chance == null) ? DEFAULT_CRC_CHECK_CHANCE : Double.parseDouble(chance); }
