Подключение к Кассандре с помощью искры в Java
Я использую cassandra 3.2.1 со свечой, я включил все необходимые банки. и я попытался подключить Кассандру из Java через искру, я получаю следующую ошибку,
Исключение в потоке "main" java.lang.NoSuchMethodError: scala.Predef$.augmentString(Ljava/lang/String;)Lscala/collection/immutable/StringOps; в akka.util.Duration$.(Duration.scala:76) в akka.util.Duration$.(Duration.scala) в akka.actor.ActorSystem$Settings.(ActorSystem.scala:120) в akka.actor.ActorSystemImpl.(ActorSystem.scala:426) в akka.actor.ActorSystem$.apply(ActorSystem.scala:103) в akka.actor.ActorSystem$.apply(ActorSystem.scala:98) в org.apache.spark.util.AkkaUtils$.org$apache$spark$util$AkkaUtils$$doCreateActorSystem(AkkaUtils.scala:122) в org.apache.spark.util.AkkaUtils$$anonfun$1.apply(AkkaUtils.scala:55) в org.apache.spark.util.AkkaUtils$$anonfun$1.apply(AkkaUtils.scala:54) в org.apache.spark.util.Utils$$anonfun$startServiceOnPort$1.apply$mcVI $sp(Utils.scala:1837) в scala.collection..immutable.Range.foreach$mVc$sp(Range.scala:142) в org.apache.spark.util.Utils$.startServiceOnPort(Utils.scala:1828) в org.apache.spark.util.AkkaUtils$.createActorSystem(AkkaUtils.scala:57) в org.apache.spark.SparkEnv$.create(SparkEnv.scala:223) в org.apache.spark.SparkEnv$.createDriverEnv(SparkEnv.scala:163) в org.apache.spark.SparkContext.createSparkEnv(SparkContext.scala:269) в org.apache.spark.SparkContext.(SparkContext.scala:272) в spark.Sample.run(Sample.java:13) в spark.Sample.main(Sample.java:23)
Есть идеи по этому поводу? и чего мне не хватает
Смотрите банки и мой пример кода на изображении ниже. Не знаю, где я делаю ошибку.