Thanks !
For reference, solved with mapping to Flink tuples.
On Wed, Sep 7, 2022 at 2:27 PM Chesnay Schepler 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.
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 wr
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 ToTupleM
