You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Soheil Pourbafrani <so...@gmail.com> on 2018/05/29 11:43:46 UTC

What is the package in Flink-Cassandra-connector, includes Cassandra datastax core

Hi, I use Flink Cassandra Connector dependency in my maven project. Other
components have conflict with the cassandra-driver-core that is embedded in
flink-cassandra-connector. I tried to exclude that in pom.xml file like
this:

<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>

but it didn't exclude cassandra-driver-core from my project, so I guess it
is embedded under another name. Can anybody tell me what is the name of the
artifact that includes class cassandra-driver-core in
flink-cassandra-connector dependency?

Re: What is the package in Flink-Cassandra-connector, includes Cassandra datastax core

Posted by Chesnay Schepler <ch...@apache.org>.

The cassandra-driver-core dependency is not relocated (i.e. renamed) in 
the cassandra connector. If it were you wouldn't have conflicts ;)

The cassandra-connector artifact is a fat-jar, and thus always contains 
this dependency. There is no way get rid of it with maven exclusions 
(outside the IDE).

Please see the last comment in FLINK-4091 
<https://issues.apache.org/jira/browse/FLINK-4091> for some workarounds.

You could also try building the connector from source; you would have to 
set the datastax dependencies to whatever version you are using and 
disable the guava relocation.

On 29.05.2018 13:43, Soheil Pourbafrani wrote:
> Hi, I use Flink Cassandra Connector dependency in my maven project. 
> Other components have conflict with the cassandra-driver-core that is 
> embedded in flink-cassandra-connector. I tried to exclude that in 
> pom.xml file like this:
>
> <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>
> but it didn't exclude cassandra-driver-core from my project, so I 
> guess it is embedded under another name. Can anybody tell me what is 
> the name of the artifact that includes class cassandra-driver-core in 
> flink-cassandra-connector dependency?
>
>
>