Противоречивость зависимостей maven при использовании соединителей Spark и Flink Cassandra - PullRequest
0 голосов
/ 29 мая 2018

Я работаю над проектом, в котором 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 работает без ошибок.Как я могу это исправить?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...