DataSource Partition Key Index Pushdowns Broken for ProtocolVersion 3
Description
After fixing the test to run against PV3 I noticed the following failing tests
[info] - should allow to select rows with indexed columns that belong to partition key *** FAILED *** (106 milliseconds)
[info] - should allow to select rows with indexed partition and regular columns *** FAILED *** (69 milliseconds)
Both of these are failing because they use CQL conventions of pushing down predicates which are not allowed in PV3.
[info] org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 3.0 failed 1 times, most recent failure: Lost task 0.0 in stage 3.0 (TID 3, localhost): java.io.IOException: Exception during preparation of SELECT "ipk1", "pk2", "d2", "id1" FROM "test_cassandra_sql_spec_1"."index_test" WHERE token("ipk1", "pk2") > ? AND token("ipk1", "pk2") <= ? AND "ipk1" = ? ALLOW FILTERING: ipk1 cannot be restricted by more than one relation if it includes an Equal
After fixing the test to run against PV3 I noticed the following failing tests
[info] - should allow to select rows with indexed columns that belong to partition key *** FAILED *** (106 milliseconds) [info] - should allow to select rows with indexed partition and regular columns *** FAILED *** (69 milliseconds)Both of these are failing because they use CQL conventions of pushing down predicates which are not allowed in PV3.
[info] org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 3.0 failed 1 times, most recent failure: Lost task 0.0 in stage 3.0 (TID 3, localhost): java.io.IOException: Exception during preparation of SELECT "ipk1", "pk2", "d2", "id1" FROM "test_cassandra_sql_spec_1"."index_test" WHERE token("ipk1", "pk2") > ? AND token("ipk1", "pk2") <= ? AND "ipk1" = ? ALLOW FILTERING: ipk1 cannot be restricted by more than one relation if it includes an Equal