Question about Java lists in Flink SQL

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Question about Java lists in Flink SQL

Jeyhun G.
Dear Flink committers,

I have an issue with Flink SQL that I was wondering if you could help me with.

I am trying to use Flink in my project and I ran into an issue. I have a DataStream that consists of POJOs. One of the fields in the POJO is of type java.util.List. I'm converting DataStream into Table, and I want to run Flink SQL query on that table. I expected to be able to use square brackets [ ] to address specific elements of the field that was of type java.util.List in the original data stream. However, I get the following error when I try to do so:
org.apache.flink.table.api.TableException: Type is not supported: ANY
I describe my issue in slightly more detail on StackOverflow. Would you be able to tell me if there is a way to treat a field that was of type java.util.List as an array in Flink SQL, in order to apply array functions on that field?

Thank you