1

我的 Riak-Spark 连接器不工作。

我可以通过以下方式启动 Spark：

    /opt/spark/bin/spark-shell \
    --jars com.fasterxml.jackson.module_jackson-module-scala_2.11-2.4.4.jar \
    --conf spark.riak.connection.host=127.0.0.1:8087 \
    --packages com.basho.riak:spark-riak-connector_2.11:1.6.3

但是当我运行时：

    import com.basho.riak.spark._
    val data = Array(1, 2, 3, 4, 5)
    val testRDD = sc.parallelize(data)

我得到了错误：

    scala> import com.basho.riak.spark._

    scala> val data = Array(1, 2, 3, 4, 5)
    data: Array[Int] = Array(1, 2, 3, 4, 5)

    scala> val testRDD = sc.parallelize(data)
    java.lang.VerifyError: class com.fasterxml.jackson.module.scala.ser.ScalaIteratorSerializer overrides final method withResolved.(Lcom/fasterxml/jackson/databind/BeanProperty;Lcom/fasterxml/jackson/databind/jsontype...

谁能帮忙安装和使用这个连接器？？？

非常感谢，J

4

1 回答 1

0

我想我设法清理了我的罐子，现在它似乎通过了这一点。无论如何。Ĵ

于 2018-02-11T23:27:42.303 回答