Repository: phoenix Updated Branches: refs/heads/master 3594bb3bd -> 424d29b93
PHOENIX-1516 Add RAND() built-in function Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/424d29b9 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/424d29b9 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/424d29b9 Branch: refs/heads/master Commit: 424d29b93f7da1b43a9427f7af226e801cd4a9a6 Parents: 3594bb3 Author: James Taylor <[email protected]> Authored: Wed Jan 21 22:33:55 2015 -0800 Committer: James Taylor <[email protected]> Committed: Wed Jan 21 22:33:55 2015 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/phoenix/mapreduce/PhoenixRecordReader.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/424d29b9/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordReader.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordReader.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordReader.java index 308f0ad..b8eb116 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordReader.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordReader.java @@ -108,6 +108,7 @@ public class PhoenixRecordReader<T extends DBWritable> extends RecordReader<Null if(queryPlan.getContext().getSequenceManager().getSequenceCount() > 0) { iterator = new SequenceResultIterator(iterator, queryPlan.getContext().getSequenceManager()); } + this.resultIterator = iterator; // Clone the row projector as it's not thread safe and would be used simultaneously by // multiple threads otherwise. this.resultSet = new PhoenixResultSet(this.resultIterator, queryPlan.getProjector().clone(),queryPlan.getContext().getStatement());
