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

Reply via email to