Impossible de se connecter Cassandra 3.0 en utilisant le connecteur cassandra Spark 1.5.0

Question

Problème - Impossible de se connecter Cassandra 3.0 en utilisant le connecteur Cassandra Spark 1.5.0

Contexte - J'ai essayé de se connecter Cassandra 3.0 à l'aide de Spark 1.5. 0 en utilisant le connecteur fourni cassandra Spark 1.5.0 mais je reçois ci-dessous erreur -

Comme par le Spark DataStax Cassandra connecteur document, il est dit que le connecteur Spark 1.5 peut être utilisé pour Cassandra 3.0 de Spark 1.5.0/1.6 .0.

Pourriez-vous me suggérer s'il vous plaît quelque chose ici?

approche Essayé

1. J'ai essayé d'exclure la dépendance goyave de streaming Spark et pot de coeur

2. Ajouté la dépendance à Goyave séparée "pom.xml"

Merci d'avance.

---

16/04/26 09:45:07 WARN TaskSetManager: Lost task 4.0 in stage 1.0 (TID 16, ip-172-31-23-23.ec2.internal): java.lang.ExceptionInInitializerError 
    at com.datastax.spark.connector.cql.DefaultConnectionFactory$.clusterBuilder(CassandraConnectionFactory.scala:35) 
    at com.datastax.spark.connector.cql.DefaultConnectionFactory$.createCluster(CassandraConnectionFactory.scala:87) 
    at 
--- 
-- 
Caused by: java.lang.IllegalStateException: Detected Guava issue #1635 which indicates that a version of Guava less than 16.01 is in use. This introduces codec resolution issues and potentially other incompatibility issues in the driver. Please upgrade to Guava 16.01 or later. 
    at com.datastax.driver.core.SanityChecks.checkGuava(SanityChecks.java:62) 
    at com.datastax.driver.core.SanityChecks.check(SanityChecks.java:36) 
    at com.datastax.driver.core.Cluster.<clinit>(Cluster.java:67) 
    ... 23 more16/04/26 09:45:07 WARN TaskSetManager: Lost task 4.0 in stage 1.0 (TID 16, ip-172-31-23-23.ec2.internal): java.lang.ExceptionInInitializerError 
    at com.datastax.spark.connector.cql.DefaultConnectionFactory$.clusterBuilder(CassandraConnectionFactory.scala:35) 
    at com.datastax.spark.connector.cql.DefaultConnectionFactory$.createCluster(CassandraConnectionFactory.scala:87) 
    at com.datastax.spark.connector.cql.CassandraConnector$.com$datastax$spark$connector$cql$CassandraConnector$$createSession(CassandraConnector.scala:153) 
    at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$2.apply(CassandraConnector.scala:148) 
    at com.datastax.spark.connector.cql.CassandraConnector$$anonfun$2.apply(CassandraConnector.scala:148) 
    at com.datastax.spark.connector.cql.RefCountedCache.createNewValueAndKeys(RefCountedCache.scala:31) 

---

Answer 1

Il y a un conflit connu entre la version Goyave livré avec le connecteur, et celui livré avec étincelle. Comment avez-vous essayé d'ombrer la bibliothèque de Guava?

Essayez d'ajouter ceci à votre fichier build.sbt:

assemblyShadeRules in assembly := Seq(
    ShadeRule.rename("com.google.**" -> "shadeio.@1").inAll 
)