Repository: cassandra Updated Branches: refs/heads/cassandra-3.0 5726625a5 -> df65a6c68
Fix bug in counter mutation serialization patch by slebresne; reviewed by iamaleksey for CASSANDRA-10073 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/df65a6c6 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/df65a6c6 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/df65a6c6 Branch: refs/heads/cassandra-3.0 Commit: df65a6c68a5d3f11121a6ebcbfbe9ef203d0078d Parents: 5726625 Author: Sylvain Lebresne <[email protected]> Authored: Sun Aug 16 18:05:11 2015 +0200 Committer: Sylvain Lebresne <[email protected]> Committed: Mon Aug 17 15:03:52 2015 +0200 ---------------------------------------------------------------------- src/java/org/apache/cassandra/db/filter/ColumnSubselection.java | 3 ++- src/java/org/apache/cassandra/db/marshal/CollectionType.java | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/df65a6c6/src/java/org/apache/cassandra/db/filter/ColumnSubselection.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/filter/ColumnSubselection.java b/src/java/org/apache/cassandra/db/filter/ColumnSubselection.java index e45dbee..b762fa5 100644 --- a/src/java/org/apache/cassandra/db/filter/ColumnSubselection.java +++ b/src/java/org/apache/cassandra/db/filter/ColumnSubselection.java @@ -180,8 +180,9 @@ public abstract class ColumnSubselection implements Comparable<ColumnSubselectio Element eltSelection = (Element)subSel; column.cellPathSerializer().serialize(eltSelection.element, out); break; + default: + throw new AssertionError(); } - throw new AssertionError(); } public ColumnSubselection deserialize(DataInputPlus in, int version, CFMetaData metadata) throws IOException http://git-wip-us.apache.org/repos/asf/cassandra/blob/df65a6c6/src/java/org/apache/cassandra/db/marshal/CollectionType.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/marshal/CollectionType.java b/src/java/org/apache/cassandra/db/marshal/CollectionType.java index 9a096d0..cc424b9 100644 --- a/src/java/org/apache/cassandra/db/marshal/CollectionType.java +++ b/src/java/org/apache/cassandra/db/marshal/CollectionType.java @@ -127,7 +127,7 @@ public abstract class CollectionType<T> extends AbstractType<T> public void validateCellValue(ByteBuffer cellValue) throws MarshalException { if (isMultiCell()) - valueComparator().validate(cellValue); + valueComparator().validateCellValue(cellValue); else super.validateCellValue(cellValue); }
