Thanks ! For reference, solved with mapping to Flink tuples.
On Wed, Sep 7, 2022 at 2:27 PM Chesnay Schepler <ches...@apache.org> wrote: > Are you running into this in the IDE, or when submitting the job to a > Flink cluster? > > If it is the first, then you're probably affected by the Scala-free Flink > efforts. Either add an explicit dependency on flink-streaming-scala or > migrate to Flink tuples. > > On 07/09/2022 14:17, Lars Skjærven wrote: > > Hello, > > When upgrading from 1.14 to 1.15 we bumped into a type issue when > attempting to sink to Cassandra (scala 2.12.13). This was working nicely in > 1.14. Any tip is highly appreciated. > > Using a MapFunction() to generate the stream of tuples: > > CassandraSink > .addSink( > mystream.map(new ToTupleMapper) > )... > > Exception: No support for the type of the given DataStream: > GenericType<scala.Tuple2> > > Or with a lambda function: > > CassandraSink > .addSink( > mystream.map((v: MyCaseClass => (v.key v.someLongValue)) > )... > > Caused by: org.apache.flink.api.common.functions.InvalidTypesException: > The generic type parameters of 'Tuple2' are missing. In many cases lambda > methods don't provide enough information for automatic type extraction when > Java generics are involved. An easy workaround is to use an (anonymous) > class instead that implements the > 'org.apache.flink.api.common.functions.MapFunction' interface. Otherwise > the type has to be specified explicitly using type information. > > > > > >
