Hi, Maybe try row-based flatMap operation in table api. It is available on flink 1.13.x
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/tableapi/#flatmap Best, Yik San -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/