Я также последовал примеру в первом документе, на который вы ссылаетесь. Вы заметите, что в разделе «Предварительные требования» шаг № 2 требует, чтобы вы создали пример как проект Maven. Шаг № 3 перечисляет четыре зависимости, которые вам нужно добавить в свой проект. Две из этих зависимостей относятся к Spark Connector:
- com.datastax.spark:spark-cassandra-connector_2.10:1.0.0-rc4
- com.datastax.spark:spark-cassandra-connector-java_2.10:1.0.0-rc4
По сути, раздел «зависимости» pom.xml для моих проектов Spark выглядит следующим образом:
<dependencies>
<dependency>
<groupId>com.datastax.spark</groupId>
<artifactId>spark-cassandra-connector_2.10</artifactId>
<version>1.1.0-alpha2</version>
</dependency>
<dependency>
<groupId>com.datastax.spark</groupId>
<artifactId>spark-cassandra-connector-java_2.10</artifactId>
<version>1.1.0-alpha2</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_2.10</artifactId>
<version>1.1.0</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming_2.10</artifactId>
<version>1.1.0</version>
</dependency>
</dependencies>
Дважды проверьте, что ваш pom.xml имеет эти зависимости, а затем вызовите Maven, чтобы локально отключить библиотеки Spark Connector. Это сработало для меня:
cd workspace/sparkTest2
mvn package
person
Aaron
schedule
19.01.2015
