Re: Moving off of TypeInformation in Flink 1.11

2022-01-07 Thread Francesco Guardiani
Hi Sofya, DataStream API doesn't use DataTypes, but it still uses TypeInformation. DataTypes and LogicalTypes are relevant only for Table API. If I understood what you're trying to do, you don't need to manually transform to Row, but you only need to define the Schema when crossing the boundary fr

Moving off of TypeInformation in Flink 1.11

2022-01-06 Thread Sofya T. Irwin
Hi, I’m moving my Flink 1.11 application onto the Blink Table Planner; and off of TypeInformation and onto DataTypes in preparation for upgrading Flink to Flink 1.13 or higher. I’m having trouble moving off of TypeInformation. Specifically I have a section of code that maps a DataStream[Messag