Hi Fanbin, Currently, over window aggregation doesn't support two-phase optimization.
Best, Jark On Tue, 23 Jun 2020 at 12:14, Fanbin Bu <fanbin...@coinbase.com> wrote: > Hi, > > Does over window aggregation support two-phase mode? > > https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/config.html#table-optimizer-agg-phase-strategy > > SELECT > user_id > , event_time > , listagg(event_type, '*') over w as names > FROM table > WINDOW w AS > ( PARTITION BY user_id > ORDER BY event_time > ROWS BETWEEN 256 PRECEDING AND CURRENT ROW > ) > >
