Hi Timo,
Row will work definitely work at this point for sure, thank you for helping
out.
I opened a jira ticket: https://issues.apache.org/jira/browse/FLINK-17442
Gyula
On Tue, Apr 28, 2020 at 6:48 PM Timo Walther wrote:
> Hi Gyula,
>
> does `toAppendStream(Row.class)` work for you? The othe
Hi Gyula,
does `toAppendStream(Row.class)` work for you? The other methods take
TypeInformation and might cause this problem. It is definitely a bug.
Feel free to open an issue under:
https://issues.apache.org/jira/browse/FLINK-12251
Regards,
Timo
On 28.04.20 18:44, Gyula Fóra wrote:
Hi Tim
Hi Timo,
I am trying to convert simply back to a DataStream. Let's say:
DataStream>
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 wrote:
> Hi Gyula,
>
> are you coming from Data
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
Hi All!
I have a Table with columns of ARRAY and ARRAY, 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: AR
