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
<https://stackoverflow.com/questions/65548786/fink-sql-cannot-convert-list-to-array>.
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

Reply via email to