You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by mc...@apache.org on 2018/05/03 09:55:44 UTC
[02/10] cassandra git commit: CqlRecordReader unnecessarily quotes
the keyspace when connecting, when the java driver will.
CqlRecordReader unnecessarily quotes the keyspace when connecting, when the java driver will.
patch by Cyril Scetbon; reviewed by Mick Semb Wever for CASSANDRA-10751
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/1b0b113f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1b0b113f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1b0b113f
Branch: refs/heads/cassandra-3.0
Commit: 1b0b113facb2d8ad125b9baa0127ffe5abe8a16e
Parents: 3a71382
Author: Mick Semb Wever <mc...@apache.org>
Authored: Tue May 1 21:00:25 2018 +1000
Committer: Mick Semb Wever <mc...@apache.org>
Committed: Thu May 3 18:39:55 2018 +1000
----------------------------------------------------------------------
CHANGES.txt | 1 +
src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/1b0b113f/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 22ee346..1055d51 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
2.2.13
+ * CqlRecordReader no longer quotes the keyspace when connecting, as the java driver will (CASSANDRA-10751)
* Fix compaction failure caused by reading un-flushed data (CASSANDRA-12743)
* Use Bounds instead of Range for sstables in anticompaction (CASSANDRA-14411)
* Fix JSON queries with IN restrictions and ORDER BY clause (CASSANDRA-14286)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/1b0b113f/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 b3e440d..18b2f50 100644
--- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
+++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
@@ -133,7 +133,7 @@ public class CqlRecordReader extends RecordReader<Long, Row>
}
if (cluster != null)
- session = cluster.connect(quote(keyspace));
+ session = cluster.connect(keyspace);
if (session == null)
throw new RuntimeException("Can't create connection session");
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org