Repository: cassandra Updated Branches: refs/heads/cassandra-2.2 3a713827f -> 1b0b113fa refs/heads/cassandra-3.0 eb68c3126 -> 493f9a2b4 refs/heads/cassandra-3.11 2d19de1cf -> 73f5b8f99 refs/heads/trunk 60ed982d5 -> dd091d417
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-2.2 Commit: 1b0b113facb2d8ad125b9baa0127ffe5abe8a16e Parents: 3a71382 Author: Mick Semb Wever <m...@apache.org> Authored: Tue May 1 21:00:25 2018 +1000 Committer: Mick Semb Wever <m...@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-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
