Apache Flink

I'm trying to integrate Flink with Hudi. I'm using the DataStream API, but I'm having trouble to create a DataStream&lt;RowData&gt;. Any sample code on how todo this?

<https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/table/data/GenericRowData.html|https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/table/data/GenericRowData.html>

SCR-20231106-lhyz.png

I always see this type error when creating a GenericRowData stream and use it in the Hudi connector

<@U04EK3JMFCM> would you be able to share a toy code example 

You should be able to simply cast it to those types since RowData is the interface for GenericRowData and DataStream is SingleOutputStreamOperator’s parent 

Cast worked, but now i run into `Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath.` But i have flink table API included in the pom and set the maven shade transformer as well. Any idea?

I'm following this: <https://hudi.apache.org/docs/flink-quick-start-guide>

Ok got it, it was the transformer added by the flink quickstart archetype that caused this