Repository: cassandra Updated Branches: refs/heads/trunk a3e041848 -> c31aef689
simplify Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c31aef68 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c31aef68 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c31aef68 Branch: refs/heads/trunk Commit: c31aef689f456533c6baf96514e2bb3445ecec07 Parents: a3e0418 Author: Dave Brosius <[email protected]> Authored: Wed May 6 13:23:04 2015 -0400 Committer: Dave Brosius <[email protected]> Committed: Wed May 6 13:23:04 2015 -0400 ---------------------------------------------------------------------- src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/c31aef68/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java index 1d8436b..132273c 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java @@ -507,9 +507,8 @@ class CqlRecordWriter extends RecordWriter<Map<String, ByteBuffer>, List<ByteBuf public List<InetAddress> getEndpoints(TokenRange range) { Set<Host> hostSet = rangeMap.get(range); - List<Host> hosts = Arrays.asList(rangeMap.get(range).toArray(new Host[rangeMap.get(range).size()])); - List<InetAddress> addresses = new ArrayList<>(hosts.size()); - for (Host host: hosts) + List<InetAddress> addresses = new ArrayList<>(hostSet.size()); + for (Host host: hostSet) { addresses.add(host.getAddress()); }
