Hi Timo,
I am trying to convert simply back to a DataStream. Let's say:
DataStream<Tuple2<String[], Integer[]>>
I can convert the DataStream into a table without a problem, the problem is
getting a DataStream back.
Thanks
Gyula
On Tue, Apr 28, 2020 at 6:32 PM Timo Walther <twal...@apache.org> wrote:
> 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
>
>
