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 j
ava.util.List as an array in Flink SQL, in order to apply array functions on that field?
Thank you