Backport fix from CASSANDRA-10806 (CASSANDRA-10935)
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e66dcc70 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e66dcc70 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e66dcc70 Branch: refs/heads/trunk Commit: e66dcc70c510eacfc2e906e1a6f4d9a2708653b3 Parents: 476b68a Author: Marcus Eriksson <[email protected]> Authored: Wed Jan 20 10:26:18 2016 +0100 Committer: Marcus Eriksson <[email protected]> Committed: Wed Jan 20 10:27:26 2016 +0100 ---------------------------------------------------------------------- src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/e66dcc70/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 5448390..3ec6965 100644 --- a/src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java +++ b/src/java/org/apache/cassandra/utils/NativeSSTableLoaderClient.java @@ -74,7 +74,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)
