Fix CRR test Patch by Mike Adamson, reviewed by brandonwilliams for CASSANDRA-7726
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7ddcf3e2 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7ddcf3e2 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7ddcf3e2 Branch: refs/heads/cassandra-2.1 Commit: 7ddcf3e2ed71116e3cbbe05de6986e28f43941d2 Parents: 7049ee0 Author: Brandon Williams <[email protected]> Authored: Tue Aug 12 13:32:51 2014 -0500 Committer: Brandon Williams <[email protected]> Committed: Tue Aug 12 13:32:51 2014 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/7ddcf3e2/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java index fa8dec9..6c75a8b 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java @@ -149,7 +149,7 @@ public class CqlRecordReader extends RecordReader<Long, Row> } if (cluster != null) - session = cluster.connect(keyspace); + session = cluster.connect(quote(keyspace)); if (session == null) throw new RuntimeException("Can't create connection session");
