(DEPRECATED) Apache Flink User Mailing List archive.

Cassandra Connector Problem (Possible Guava Conflict?)

Classic

List

Threaded

6 messages Options

Eamon Kavanagh

Cassandra Connector Problem (Possible Guava Conflict?)

Hey everyone,

I'm having an issue using the Flink -> Cassandra connector. The error message I get is:

Class com.datastax.driver.core.DefaultResultSetFuture does not implement the requested interface org.apache.flink.shaded.com.google.common.util.concurrent.ListenableFuture

I believe the problem is related to this (https://github.com/apache/flink/pull/2133) pull request but it still results in this error. Does anyone have any advice on how to debug it?

Thanks,

Eamon

Chesnay Schepler

Re: Cassandra Connector Problem (Possible Guava Conflict?)

The problem is that the cassandra jar currently contains 2 shaded guavas.
I already have a fix ready that suppressed the root-poms shade plugin configuration inside the cassandra submit.

I will submit that next week.

On 26.06.2016 17:46, Eamon Kavanagh wrote:

Hey everyone,

I'm having an issue using the Flink -> Cassandra connector. The error message I get is:

Class com.datastax.driver.core.DefaultResultSetFuture does not implement the requested interface org.apache.flink.shaded.com.google.common.util.concurrent.ListenableFuture

I believe the problem is related to this (https://github.com/apache/flink/pull/2133) pull request but it still results in this error. Does anyone have any advice on how to debug it?

Thanks,

Eamon

Eamon Kavanagh

Re: Cassandra Connector Problem (Possible Guava Conflict?)

Hey Chesnay,

Thanks for the response. Is there anything I can do in the short term to skirt the issue?

On Sun, Jun 26, 2016 at 11:55 AM, Chesnay Schepler <[hidden email]> wrote:

The problem is that the cassandra jar currently contains 2 shaded guavas.
I already have a fix ready that suppressed the root-poms shade plugin configuration inside the cassandra submit.

I will submit that next week.

On 26.06.2016 17:46, Eamon Kavanagh wrote:

Hey everyone,

I'm having an issue using the Flink -> Cassandra connector. The error message I get is:

Class com.datastax.driver.core.DefaultResultSetFuture does not implement the requested interface org.apache.flink.shaded.com.google.common.util.concurrent.ListenableFuture

I believe the problem is related to this (https://github.com/apache/flink/pull/2133) pull request but it still results in this error. Does anyone have any advice on how to debug it?

Thanks,

Eamon

Chesnay Schepler

Re: Cassandra Connector Problem (Possible Guava Conflict?)

Replace the maven shade plugin section in the flink-cassandra pom with the following,
or apply the additions(in bold) manually:

            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-shade-plugin</artifactId>
                <version>2.4.1</version>
                <executions>
                    
                    <execution>
                        <id>shade-flink</id>
                        <phase>package</phase>
                        <goals>
                            <goal>shade</goal>
                        </goals>
                        <configuration combine.self="override">
                            <artifactSet>
                                <includes>
                                    <include>com.datastax.cassandra:cassandra-driver-core</include>
                                    <include>com.datastax.cassandra:cassandra-driver-mapping</include>
                                    <include>com.google.guava:guava</include>
                                </includes>
                            </artifactSet>
                            <relocations>
                                <relocation>
                                    <pattern>com.google</pattern>
                                    <shadedPattern>org.apache.flink.cassandra.shaded.com.google</shadedPattern>
                                    <excludes>
                                        <exclude>com.google.protobuf.**</exclude>
                                        <exclude>com.google.inject.**</exclude>
                                    </excludes>
                                </relocation>
                            </relocations>
                        </configuration>
                    </execution>
                </executions>
            </plugin>

On 26.06.2016 18:00, Eamon Kavanagh wrote:

Hey Chesnay,

Thanks for the response. Is there anything I can do in the short term to skirt the issue?

On Sun, Jun 26, 2016 at 11:55 AM, Chesnay Schepler <[hidden email]> wrote:

The problem is that the cassandra jar currently contains 2 shaded guavas.
I already have a fix ready that suppressed the root-poms shade plugin configuration inside the cassandra submit.

I will submit that next week.

On 26.06.2016 17:46, Eamon Kavanagh wrote:

Hey everyone,

I'm having an issue using the Flink -> Cassandra connector. The error message I get is:

Class com.datastax.driver.core.DefaultResultSetFuture does not implement the requested interface org.apache.flink.shaded.com.google.common.util.concurrent.ListenableFuture

I believe the problem is related to this (https://github.com/apache/flink/pull/2133) pull request but it still results in this error. Does anyone have any advice on how to debug it?

Thanks,

Eamon

Eamon Kavanagh

Re: Cassandra Connector Problem (Possible Guava Conflict?)

Perfect, that worked. Thanks!

On Sun, Jun 26, 2016 at 12:56 PM, Chesnay Schepler <[hidden email]> wrote:

Replace the maven shade plugin section in the flink-cassandra pom with the following,
or apply the additions(in bold) manually:

            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-shade-plugin</artifactId>
                <version>2.4.1</version>
                <executions>
                    
                    <execution>
                        <id>shade-flink</id>
                        <phase>package</phase>
                        <goals>
                            <goal>shade</goal>
                        </goals>
                        <configuration combine.self="override">
                            <artifactSet>
                                <includes>
                                    <include>com.datastax.cassandra:cassandra-driver-core</include>
                                    <include>com.datastax.cassandra:cassandra-driver-mapping</include>
                                    <include>com.google.guava:guava</include>
                                </includes>
                            </artifactSet>
                            <relocations>
                                <relocation>
                                    <pattern>com.google</pattern>
                                    <shadedPattern>org.apache.flink.cassandra.shaded.com.google</shadedPattern>
                                    <excludes>
                                        <exclude>com.google.protobuf.**</exclude>
                                        <exclude>com.google.inject.**</exclude>
                                    </excludes>
                                </relocation>
                            </relocations>
                        </configuration>
                    </execution>
                </executions>
            </plugin>

On 26.06.2016 18:00, Eamon Kavanagh wrote:

Hey Chesnay,

Thanks for the response. Is there anything I can do in the short term to skirt the issue?

On Sun, Jun 26, 2016 at 11:55 AM, Chesnay Schepler <[hidden email][hidden email]> wrote:

The problem is that the cassandra jar currently contains 2 shaded guavas.
I already have a fix ready that suppressed the root-poms shade plugin configuration inside the cassandra submit.

I will submit that next week.

On 26.06.2016 17:46, Eamon Kavanagh wrote:

Hey everyone,

I'm having an issue using the Flink -> Cassandra connector. The error message I get is:

Class com.datastax.driver.core.DefaultResultSetFuture does not implement the requested interface org.apache.flink.shaded.com.google.common.util.concurrent.ListenableFuture

I believe the problem is related to this (https://github.com/apache/flink/pull/2133) pull request but it still results in this error. Does anyone have any advice on how to debug it?

Thanks,

Eamon

AndreaKinn

Re: Cassandra Connector Problem (Possible Guava Conflict?)

In reply to this post by Chesnay Schepler

Hi,
I have the same problem but trying your solution so substituting this:

<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>2.4.1</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<artifactSet>
<excludes combine.self="override"></excludes>
</artifactSet>
</configuration>
</execution>
</executions>
</plugin>

with :

<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>2.4.1</version>
<executions>

<execution>
<id>shade-flink</id>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration combine.self="override">
<artifactSet>
<includes>

<include>com.datastax.cassandra:cassandra-driver-core</include>

<include>com.datastax.cassandra:cassandra-driver-mapping</include>

<include>com.google.guava:guava</include>
</includes>
</artifactSet>
<relocations>
<relocation>
<pattern>com.google</pattern>

<shadedPattern>org.apache.flink.cassandra.shaded.com.google</shadedPattern>
<excludes>

<exclude>com.google.protobuf.**</exclude>

<exclude>com.google.inject.**</exclude>
</excludes>
</relocation>
</relocations>
</configuration>
</execution>
</executions>
</plugin>

Eclipse shows me a non specified error:
<configuration combine.self="override">

--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/