Я работаю над проектом, в котором Apache Flink и Apache Spark пытаются читать / записывать данные из / в Apache Cassandra, поэтому я должен использовать коннекторы Spark и Flink Cassandra Maven, которые оба имеют следующую подзависимость:
<dependency>
<groupId>com.datastax.cassandra</groupId>
<artifactId>cassandra-driver-core</artifactId>
<version>*</version>
</dependency>
Моя проблема возникнет, когда я попытаюсь использовать Spark для чтения / записи с / на Кассандру.Ошибка обсуждалась здесь и здесь .Я хочу знать, как я могу решить конфликты в Maven?Я пытался исключить пакет cassandra-driver-core
:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-cassandra_2.11</artifactId>
<version>1.4.2</version>
<exclusions>
<exclusion>
<groupId>com.datastax.cassandra</groupId>
<artifactId>cassandra-driver-core</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.datastax.spark</groupId>
<artifactId>spark-cassandra-connector_2.11</artifactId>
<version>2.0.8</version>
<exclusions>
<exclusion>
<groupId>com.datastax.cassandra</groupId>
<artifactId>cassandra-driver-core</artifactId>
</exclusion>
</exclusions>
</dependency>
, но без различий!Просто когда я удаляю Flink-Cassandra-connector
зависимость Maven, Spark работает без ошибок.Как я могу это исправить?