You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2014/08/12 20:45:15 UTC
[02/10] git commit: Fix CRR test
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.0
Commit: 7ddcf3e2ed71116e3cbbe05de6986e28f43941d2
Parents: 7049ee0
Author: Brandon Williams <br...@apache.org>
Authored: Tue Aug 12 13:32:51 2014 -0500
Committer: Brandon Williams <br...@apache.org>
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");