RE: PyFlink convert data from ds to table

2021-12-08 Thread Королькевич Михаил
I found the problem.In the data stream I had an empty list, but not none (null) On 2021/12/08 13:11:31 Королькевич Михаил wrote:> Hello, Flink team!>> 1) Is it possible to save a python list to table from datastream?>> 2) and then save the accumulated data to avro file?>> For example, my data strea

PyFlink convert data from ds to table

2021-12-08 Thread Королькевич Михаил
Hello, Flink team!1) Is it possible to save a python list to table from datastream?2) and then save the accumulated data to avro file? For example, my data stream has the type. Types.ROW_NAMED(['id', 'items'], [Types.STRING, Types.LIST(items_row)] ) items_row  = Types.ROW_NAMED(field_names=['start'