Hi Gyula,
are you coming from DataStream API or are you trying to implement a
source/sink? It looks like the array is currently serialized with Kryo.
I would recommend to take a look at this class:
org.apache.flink.table.types.utils.LegacyTypeInfoDataTypeConverter
This is the current mapping between old TypeInformation and new DataType
system. A back and forth conversion should work between those types.
Regards,
Timo
On 28.04.20 15:36, Gyula Fóra wrote:
Hi All!
I have a Table with columns of ARRAY<STRING> and ARRAY<INT>, is there
any way to convert it back to the respective java arrays? String[] and
Integer[]
It only seems to work for primitive types (non null), date, time and
decimal.
For String for instance I get the following error:
Query schema: [f0: ARRAY<STRING>]
Sink schema: [f0: LEGACY('ARRAY', 'ANY<[Ljava.lang.String;,....
Am I doing something wrong?
Thanks
Gyula
