Monday 14 March 2016

Spark Cassandra Connector Issues

1. Libraries conflicts Error: java.io.IOException: Failed to open native connection to Cassandra at {192.168.0.1}:9042**

 To solve it, use Cassandra core driver 2.1.5

 2. HiveContext doesn't compatible with Cassandra connector Exception in thread "main" java.lang.RuntimeException: Failed to load class for data source: org.apache.spark.sql.cassandra

 To solve it, use SQLContext instead of HiveContext

 3. Alter Cassandra columns in a loop, only partial is changed. Reason is unknown yet.

No comments:

Post a Comment