Re: Return value of newQueryPlan

2016-09-04 Thread Eric Stevens
For question 2, you can't inform the coordinator that you want it to use a certain node to fulfill the answer. It'll ask several and use the first count which answer that satisfy the consistency constraints. On Fri, Sep 2, 2016, 1:19 PM Siddharth Verma wrote: > I am debugging an issue at our clu

Re: Reading cassandra table using Spark

2016-09-04 Thread DuyHai Doan
"com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured columnfamily size_estimates" --> this error message occurs usually when using a version of the Java driver (thus the Spark/Cassandra connector version) not aligned with Cassandra version Please give - C* version - Spark/C*

Reading cassandra table using Spark

2016-09-04 Thread Selvam Raman
Hi, i am trying to read cassandra table as Dataframe but got the below issue spark-shell --packages com.datastax.spark:spark-cassandra-connector_2.10:1.3.0 --conf spark.cassandra.connection.host=** val df = sqlContext.read. | format("org.apache.spark.sql.cassandra"). | options(Map(