m.google
>
>
> com.google.protobuf.**
>
> com.google.inject.**
>
>
>
>
>
>
>
>
>
> On 26.06.2016 18:00, Eamon Kavanagh wrote:
e 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.
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 prob
.execute("WriteTupleIntoCassandra")
}
On Mon, Jun 20, 2016 at 10:53 PM, Jamie Grier
wrote:
> This looks like a simple type mismatch. It's impossible to help with this
> without seeing your code, though. Can you post it here? Thanks.
>
> -Jamie
>
>
> On Sun,
Hey Mailing List,
I'm trying to use the Cassandra connector that came out recently (
https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/cassandra.html)
in Scala but I'm having trouble with types when I use
CassandraSink.addSink(in: DataStream).
If I don't define the
Hey Support,
I'm trying to use Flink's Elasticsearch connector but I'm having trouble.
When I add the dependency seen here (
https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/elasticsearch2.html)
to my pom file, IntelliJ can't find it. I also can't find it on the ma
