Repository: cassandra Updated Branches: refs/heads/cassandra-3.0 363e7bd71 -> ed96322a0 refs/heads/trunk abf7df3bd -> 37986e825
Fix sstableloader not working with upper case keyspace name patch by Alex Liu; reviewed by yukim for CASSANDRA-10806 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/ed96322a Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/ed96322a Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/ed96322a Branch: refs/heads/cassandra-3.0 Commit: ed96322a0dfc106e2270a7d0b9930a5311eadcbf Parents: 363e7bd Author: Alex Liu <[email protected]> Authored: Wed Dec 16 14:34:24 2015 -0600 Committer: Yuki Morishita <[email protected]> Committed: Wed Dec 16 14:34:24 2015 -0600 ---------------------------------------------------------------------- CHANGES.txt | 1 + src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/ed96322a/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 10504c7..7677e38 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.0.3 + * Fix sstableloader not working with upper case keyspace name (CASSANDRA-10806) Merged from 2.2: * Add new types to Stress (CASSANDRA-9556) * Add property to allow listening on broadcast interface (CASSANDRA-9748) http://git-wip-us.apache.org/repos/asf/cassandra/blob/ed96322a/src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java b/src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java index 840ef26..bb927fc 100644 --- a/src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java +++ b/src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java @@ -75,7 +75,7 @@ public class NativeSSTableLoaderClient extends SSTableLoader.Client for (TokenRange tokenRange : tokenRanges) { - Set<Host> endpoints = metadata.getReplicas(keyspace, tokenRange); + Set<Host> endpoints = metadata.getReplicas(Metadata.quote(keyspace), tokenRange); Range<Token> range = new Range<>(tokenFactory.fromString(tokenRange.getStart().getValue().toString()), tokenFactory.fromString(tokenRange.getEnd().getValue().toString())); for (Host endpoint : endpoints)
