scala – 带有组装jar的spark-cassandra-connector的NoSuchMetho

我是Scala的新手,我正在尝试建立一个Spark工作.我已经构建了一个包含DataStax连接器的ajob并将其组装成一个胖罐.当我尝试执行它时,它失败并出现java.lang.NoSuchMethodError.我已经破解了JAR,可以看到包含了DataStax库.我错过了一些明显的东西吗有关这个过程的好教程吗？

谢谢

安慰
????$spark-submit –class org.bobbrez.CasCountJob ./target/scala-2.11/bobbrez-spark-assembly-0.0.1.jar ks tn
????…
????线程“main”中的异常java.lang.NoSuchMethodError：scala.runtime.ObjectRef.zero()Lscala / runtime / ObjectRef;
????????at com.datastax.spark.connector.cql.CassandraConnector $.com $datastax $spark $connector $cql $CassandraConnector $$createSession(CassandraConnector.scala)
????????在com.datastax.spark.connector.cql.CassandraConnector $$anonfun $2.apply(CassandraConnector.scala：148)
????????…

build.sbt

name := "soofa-spark"

version := "0.0.1"

scalaVersion := "2.11.7"

// additional libraries
libraryDependencies += "org.apache.spark" %% "spark-core" % "1.6.0" %     "provided"
libraryDependencies += "com.datastax.spark" %% "spark-cassandra-connector" % "1.5.0-M3"
libraryDependencies += "com.typesafe" % "config" % "1.3.0"

mergeStrategy in assembly <<= (mergeStrategy in assembly) { (old) =>
  {
    case m if m.toLowerCase.endsWith("manifest.mf") => MergeStrategy.discard
    case m if m.startsWith("META-INF") => MergeStrategy.discard
    case PathList("javax","servlet",xs @ _*) => MergeStrategy.first
    case PathList("org","apache","jboss",xs @ _*) => MergeStrategy.first
    case "about.html"  => MergeStrategy.rename
    case "reference.conf" => MergeStrategy.concat
    case _ => MergeStrategy.first
  }
}

CasCountJob.scala

package org.bobbrez

// Spark
import org.apache.spark.{SparkContext,SparkConf}
import com.datastax.spark.connector._

object CasCountJob {
  private val AppName = "CasCountJob"

  def main(args: Array[String]) {
    println("Hello world from " + AppName)

    val keyspace = args(0)
    val tablename = args(1)

    println("Keyspace: " + keyspace)
    println("Table: " + tablename)

    // Configure and create a Scala Spark Context.
    val conf = new SparkConf(true)
                .set("spark.cassandra.connection.host","HOSTNAME")
                .set("spark.cassandra.auth.username","USERNAME")
                .set("spark.cassandra.auth.password","PASSWORD")
                .setAppName(AppName)

    val sc = new SparkContext(conf)

    val rdd = sc.cassandraTable(keyspace,tablename)
    println("Table Count: " + rdd.count)

    System.exit(0)
  }
}