flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jamie Grier <ja...@data-artisans.com>
Subject Re: Cassamdra Connector in Scala
Date Tue, 21 Jun 2016 02:53:51 GMT
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 <kavanagh.c.eamon@gmail.com>
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>
jamie@data-artisans.com

Mime
View raw message