You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ja...@apache.org on 2015/05/07 20:09:14 UTC
cassandra git commit: StreamingTransferTest fails under
test-compression due to bad assertion
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 <ja...@apache.org>
Authored: Thu May 7 14:08:00 2015 -0400
Committer: T Jake Luciani <ja...@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