From 1b0b113facb2d8ad125b9baa0127ffe5abe8a16e Mon Sep 17 00:00:00 2001 From: Mick Semb Wever Date: Tue, 1 May 2018 21:00:25 +1000 Subject: [PATCH] CqlRecordReader unnecessarily quotes the keyspace when connecting, when the java driver will. patch by Cyril Scetbon; reviewed by Mick Semb Wever for CASSANDRA-10751 --- CHANGES.txt | 1 + src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/CHANGES.txt b/CHANGES.txt index 22ee3460b3..1055d51d1a 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) diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java index b3e440d58c..18b2f500d7 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 } if (cluster != null) - session = cluster.connect(quote(keyspace)); + session = cluster.connect(keyspace); if (session == null) throw new RuntimeException("Can't create connection session");