Fehler beim Verbinden Cloudant DB von meinem lokalen Spark-Cluster (PySpark) unter Verwendung von Funken cloudant Stecker

Question

I am getting the following error while connecting Cloudant DB from my local Spark cluster(PySpark) using spark-cloudant connector. 

    The spark-cloudant connector is: https://spark-packages.org/package/cloudant-labs/spark-cloudant 

    I am started my PySpark with following command, 
    pyspark2.cmd --jars "all jars for spark-cloudant connector" 

The code I am using, 
sqlContextNew = SQLContext(sc) 
booksDataDF = sqlContextNew.read.format("com.cloudant.spark").option("cloudant.host","AAA-HOST").option("cloudant.username", "BBB-USERNAME"). option("cloudant.password","CCC-PASSWORD").load("booksdata") 

Die Fehlermeldung ist: 16/07/22 23.01.51 INFO JsonStoreDataAccess: SparkEnv ActorSystem Wiederverwendung als es enthält spray 16/07/22 23.01.52 eRROR ActorSystemImpl: Uncaught fataler Fehler von Faden [sparkDriverActorSystem-akka.actor.default-Dispatcher-2] Abschalten ActorSystem [sparkDriverActorSystem] java.lang.ExceptionInInitializerError

verursacht durch : java.lang.NoSuchMethodError: scala.Predef $ ArrowAssoc $ .erweiterung $$ minus $ greater (Ljava/lang/Objekt; Ljava/lang/Objekt;) Lscala/Tuple2 bei org.parboiled.scala.Parser $ class.rule (Parser.scala: 73) bei org.parboiled.scala.Parser $ class.rule (Parser.scala: 46) bei spray.http.parser.HttpParser $ .rule (HttpParser.scala: 29) unter spray.http.parser.CORSHeaders $ class. $ timesAccess $ minusControl $ minusMax $ minusAge (CORSHeaders.scala: 59) at spray.http.parser.HttpParser $. $ timesAccess $ minusControl $ minusMax $ minusAge (HttpParser.scala: 29)

Answer 1

Ich vermute, dass dieser Fehler wegen der falschen Scala-Version ist. Was ist die Scala-Version, die Sie verwenden? Für Funken und Funkenwolken benötigen Sie Scala 2.10.