Cassandra Connector Problem (Possible Guava Conflict?)

[Eamon Kavanagh]

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

Re: Cassandra Connector Problem (Possible Guava Conflict?)

[Chesnay Schepler]

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

Re: Cassandra Connector Problem (Possible Guava Conflict?)

[Eamon Kavanagh]

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

Re: Cassandra Connector Problem (Possible Guava Conflict?)

[Chesnay Schepler]

Replace the maven shade plugin section in the flink-cassandra pom with 
the following,

or apply the additions(in bold) manually:


org.apache.maven.plugins
maven-shade-plugin
2.4.1



*shade-flink*
package

shade




com.datastax.cassandra:cassandra-driver-core
com.datastax.cassandra:cassandra-driver-mapping
com.google.guava:guava




com.google
org.apache.flink.cassandra.shaded.com.google

com.google.protobuf.**
com.google.inject.**








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

Re: Cassandra Connector Problem (Possible Guava Conflict?)

[Eamon Kavanagh]

Perfect, that worked.  Thanks!

On Sun, Jun 26, 2016 at 12:56 PM, Chesnay Schepler 
wrote:

> Replace the maven shade plugin section in the flink-cassandra pom with the
> following,
> or apply the additions(in bold) manually:
>
> 
> org.apache.maven.plugins
> maven-shade-plugin
> 2.4.1
> 
> 
> 
> *shade-flink*
> package
> 
> shade
> 
> 
> 
> 
>
> com.datastax.cassandra:cassandra-driver-core
>
> com.datastax.cassandra:cassandra-driver-mapping
>
> com.google.guava:guava
> 
> 
> 
> 
> com.google
>
> org.apache.flink.cassandra.shaded.com.google
> 
>
> com.google.protobuf.**
>
> com.google.inject.**
> 
> 
> 
> 
> 
> 
> 
>
>
> 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 < 
> ches...@apache.org> 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
>>
>>
>>
>
>

Re: Cassandra Connector Problem (Possible Guava Conflict?)

[AndreaKinn]

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



org.apache.maven.plugins

maven-shade-plugin
2.4.1



package


shade













with :


org.apache.maven.plugins
maven-shade-plugin
2.4.1



shade-flink
package

shade




   
com.datastax.cassandra:cassandra-driver-core
   
com.datastax.cassandra:cassandra-driver-mapping
   
com.google.guava:guava




com.google
   
org.apache.flink.cassandra.shaded.com.google

   
com.google.protobuf.**
   
com.google.inject.**








Eclipse shows me a non specified error: 





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