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