CassandraJavaUtil joinWithCassandraTable throwing error for table name with mixed case

Question

question

rjain asked · Jul 13 at 11:10 AM

CassandraJavaUtil joinWithCassandraTable throwing error for table name with mixed case

I am running Spark Report on spark version 2.4.4 on Cassandra where I am joining two tables and using RDD CassandraJavaUtil javafunctions joinWithCassandraTable with first param of keyspace_name [ all lower case letters ] "abc " and second param of table_name [ mix of lowercase and upper case letters ] "xyZ" , then i am getting error Couldn't find table "xyz" in keyspace "abc". As connector i guess lowers all characters and searching the lowercase letter table name which does not exist in keyspace.

I used escaped character for mixed letter table name "xy\"Z\"" . But still I am getting the same error. Couldn't find table "xyZ" in keyspace "abc". Found similar tables in the keyspace abc.xyZ

How can use the joinWithCassandraTable for mixed letters table name as escaped characters not working for mixed letters table name.

spark-cassandra-connector

10 |1000 characters needed characters left characters exceeded

Attachments: Up to 8 attachments (including images) can be used with a maximum of 1.0 MiB each and 10.0 MiB total.

Answer 1 · 2021-07-13T11:19:17Z

Erick Ramirez answered · Jul 13 at 11:19 AM

I've got a feeling that mixed-case keyspace and table names are not supported in some parts of the connector.

I'm going to reach out to the Analytics team here at DataStax and will either get them to respond to directly or I will update my answer. Cheers!

2 Share

10 |1000 characters needed characters left characters exceeded

Attachments: Up to 8 attachments (including images) can be used with a maximum of 1.0 MiB each and 10.0 MiB total.

rjain · Jul 13 at 02:14 PM

[Duplicate post]

0 ·

rjain · Jul 13 at 02:17 PM

Hi Erick,

Thanks for your response. One correction in the above question

I used escaped character for mixed letter table name "\"xyZ\"" rather "xy"\Z\"" typo mistake.

Also, attaching exception trace below:

21/07/13 11:43:35 INFO CassandraConnector: Connected to Cassandra cluster.

java.io.IOException: Couldn't find table 'xyZ' in abc - Found similar tables in that keyspace:

abc.xyZ

at com.datastax.spark.connector.cql.Schema$.tableFromCassandra(Schema.scala:430)

0 ·

Answer 2 · 2021-07-13T14:38:58Z

jaroslaw.grabowski_50515 answered · Jul 13 at 02:38 PM

Hi! You need to check the table name via cqlsh with

describe keyspace <your keyspace>;

Use the name that you'll find in the output.

If the name is quoted, use the correct casing in joinWithCassandraTable. If the name is not quoted (should be lowercased in that case), use lowercased name in `jwct`.

1 Share

10 |1000 characters needed characters left characters exceeded

Attachments: Up to 8 attachments (including images) can be used with a maximum of 1.0 MiB each and 10.0 MiB total.

rjain · Jul 13 at 05:28 PM

Hi jaroslaw,

Thanks, I typed describe keyspace payment;

O/P:

CREATE TABLE payment."paymentHistory" (

key text PRIMARY KEY,

"c:code text

)

Tried following Casing in JoinwithCassandraTable API

1) Added the table name ( paymentHistory ) with same casing as its found in describe command output below:

CassandraJavaUtil.javaFunctions(rdd).joinWithCassandraTable("payment","paymentHistory",,,,)

Error :

Caused by: com.datastax.oss.driver.api.core.servererrors.InvalidQueryException: unconfigured table paymenthistory at com.datastax.oss.driver.api.core.servererrors.InvalidQueryException.copy(InvalidQueryException.java)

2) Adding escaped double quote character in tablename ( \"paymentHistory\" )as below:

CassandraJavaUtil.javaFunctions(rdd).joinWithCassandraTable("payment","\"paymentHistory\"",,,,)

Err:

Couldn't find table "paymentHistory" in payment.

payment.paymentHistory

Version:

spark-cass-connector-3.0.0

spark-3.0.1

0 ·

question