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, Jun 19, 2016 at 3:17 PM, Eamon Kavanagh <[email protected]> wrote: > 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 type it can't seem to properly infer it and if I do > define the type I still get an error saying there's a type mismatch. The > compile errror is > > *error: type arguments [(String, String, Int),Any] do not conform to > method addSink's type parameter bounds [IN,T <: > org.apache.flink.api.java.tuple.Tuple]* > > Is this a Scala issue? Should I switch over to Java? > > > Thanks! > Eamon > -- Jamie Grier data Artisans, Director of Applications Engineering @jamiegrier <https://twitter.com/jamiegrier> [email protected]
