Hi Luke,
This issue has been fixed in FLINK-25645 [1]. You can try 1.16 and later
versions of flink.
[1] https://issues.apache.org/jira/browse/FLINK-25645
Best,
Shammon FY
On Tue, May 2, 2023 at 12:18 PM Luke Xiong wrote:
> Many thanks if anybody could help. I ran into this in version 1.15.
>
Many thanks if anybody could help. I ran into this in version 1.15.
I have a DataStream of a custom type *X* which has a field *foo* of
type *Map*. I need to query this DataStream to find elements that meet the
conditions like *foo['bar'] == value*.
The table is created with
*tenv.createTemporary
