fix bad comparison in hadoop cf recorder reader patch by dbrosius; reviewed by jbellis for CASSANDRA-3788
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b60101c9 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b60101c9 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b60101c9 Branch: refs/heads/trunk Commit: b60101c9aa2ef123e7c38dc8397e4e415b34cb8c Parents: f5f3065 Author: Jonathan Ellis <[email protected]> Authored: Thu Jan 26 01:19:38 2012 -0600 Committer: Jonathan Ellis <[email protected]> Committed: Thu Jan 26 01:33:23 2012 -0600 ---------------------------------------------------------------------- .../cassandra/hadoop/ColumnFamilyRecordReader.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b60101c9/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java index e315ced..3c0360d 100644 --- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java +++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java @@ -461,7 +461,7 @@ public class ColumnFamilyRecordReader extends RecordReader<ByteBuffer, SortedMap } // nothing new? reached the end - if (lastRow != null && (rows.get(0).key.equals(lastRow.key) || rows.get(0).columns.get(0).column.equals(startColumn))) + if (lastRow != null && (rows.get(0).key.equals(lastRow.key) || rows.get(0).columns.get(0).column.name.equals(startColumn))) { rows = null; return;
