Hi Yuval, Can you try toDataStream[RowData](tableSchema.toPhysicalRowDataType.bridgedTo(classOf[RowData]))?
Best regards, Nico On Thu, Oct 28, 2021 at 10:15 PM Yuval Itzchakov <yuva...@gmail.com> wrote: > Flink 1.14 > Scala 2.12.5 > > Hi, > I want to be able to convert a Table into a DataStream[RowData]. I need to > do this since I already have specific infrastructure in place that knows > how to serialize RowData into a JSON format. Previously when using > toAppendStream[RowData], this worked fine. > > However, now with the new toDataStream API, I don't see a direct way to do > this. Using toDataStream[RowData](tableSchema.toPhysicalRowDataType) still > creates an internal OutputConversionOperator and yields a Row to the Kafka > sink I'm trying to use. > > Would love some help. > > -- > Best Regards, > Yuval Itzchakov. >
