You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ma...@apache.org on 2016/01/20 10:31:04 UTC

[02/10] cassandra git commit: Backport fix from CASSANDRA-10806 (CASSANDRA-10935)

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/cassandra-3.0
Commit: e66dcc70c510eacfc2e906e1a6f4d9a2708653b3
Parents: 476b68a
Author: Marcus Eriksson <ma...@apache.org>
Authored: Wed Jan 20 10:26:18 2016 +0100
Committer: Marcus Eriksson <ma...@apache.org>
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)