StreamPhysicalWindowAggregate doesn't support consuming update and delete changes

Question

de

the t_window is cdc table.

sql:

select organization_id,window_start,window_end,count(1) as cnt
from TABLE(TUMBLE(TABLE t_window,descriptor(took_at),interval '1' days))
group by organization_id,window_start,window_end;

error:

org.apache.flink.table.api.TableException: StreamPhysicalWindowAggregate doesn't support consuming update and delete changes which is produced by node TableSourceScan(table=[[emr_hive, default, t_window]], fields=[id, organization_id, took_at]).

please help!