Spark-Riak Connector не работает: проблемы с классом протоколирования

Я получил эту ошибку при попытке сохранить RDD в riak:

    import org.apache.spark.{SparkContext, SparkConf}
    import com.basho.riak.spark._
    import com.basho.riak.spark.writer.{WriteDataMapper, WriteDataMapperFactory}

    # Create an RDD with some test data and save to Riak KV bucket:
    val data = Array(1, 2, 3, 4, 5)
    val testRDD = sc.parallelize(data)
    testRDD.foreach(println)
    testRDD.saveToRiak("kv_bucket_a")

    ...
    scala> testRDD.saveToRiak("kv_bucket_a")

ошибка: отсутствует или недопустимая зависимость при загрузке файла класса 'RiakConnector.class'. Не удалось получить доступ к типу Logging в пакете org.apache.spark, поскольку он (или его зависимости) отсутствует. Проверьте ваши определения сборки...

Кто-нибудь может помочь в этом вопросе? Заранее спасибо, J

0 ответов

Другие вопросы по тегам