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(