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