Repository: cassandra Updated Branches: refs/heads/trunk 6d5b0b45a -> 0ede9ec93
StreamingTransferTest fails under test-compression due to bad assertion patch by Ariel Weisberg; reviewed by tjake for CASSANDRA-9276 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0ede9ec9 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0ede9ec9 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0ede9ec9 Branch: refs/heads/trunk Commit: 0ede9ec938e082f266bcebb56f1bdb5415dc798a Parents: 6d5b0b4 Author: T Jake Luciani <j...@apache.org> Authored: Thu May 7 14:08:00 2015 -0400 Committer: T Jake Luciani <j...@apache.org> Committed: Thu May 7 14:08:00 2015 -0400 ---------------------------------------------------------------------- .../cassandra/streaming/compress/CompressedStreamReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/0ede9ec9/src/java/org/apache/cassandra/streaming/compress/CompressedStreamReader.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/streaming/compress/CompressedStreamReader.java b/src/java/org/apache/cassandra/streaming/compress/CompressedStreamReader.java index 46f7d4f..89773ea 100644 --- a/src/java/org/apache/cassandra/streaming/compress/CompressedStreamReader.java +++ b/src/java/org/apache/cassandra/streaming/compress/CompressedStreamReader.java @@ -82,7 +82,7 @@ public class CompressedStreamReader extends StreamReader { for (Pair<Long, Long> section : sections) { - assert in.getBytesRead() < totalSize; + assert cis.getTotalCompressedBytesRead() <= totalSize; int sectionLength = (int) (section.right - section.left); // skip to beginning of section inside chunk