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
