Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3793
Thanks for the PR @suez1224. I think we need to rework this PR a little
bit, before we can merge it. I saw that you had problems using basic type
arrays such as `Integer[]`. I think we should cover this in a separate issue,
because adding a type involves changes in multiple files and needs good tests.
I would propose to introduce `LogicalUnnestRule` that convert the logical
plan into a logical `FlinkLogicalCorrelate`. This approach would not require a
`DataStreamCorrelateUnnestRule` and would work for both batch and streaming.
What do you think?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
