Jane Chan created FLINK-31013: --------------------------------- Summary: SessionWindowAggregation cannot get trigger window using event time Key: FLINK-31013 URL: https://issues.apache.org/jira/browse/FLINK-31013 Project: Flink Issue Type: Bug Components: Table Store Affects Versions: table-store-0.4.0 Reporter: Jane Chan Fix For: table-store-0.4.0
{code:java} -- test against Flink 1.16.0 create catalog fscat with ( 'type' = 'table-store', 'warehouse' = 'file:///tmp/fscat' ); use catalog fscat; create table events ( `id` int, `type` string, `date` TIMESTAMP(3), watermark for `date` AS `date`); insert into events values (1, 'T1', to_timestamp('2018-01-24', 'yyyy-MM-dd')), (2, 'T1', to_timestamp('2018-01-26', 'yyyy-MM-dd')), (1, 'T2', to_timestamp('2018-01-28', 'yyyy-MM-dd')), (1, 'T2', to_timestamp('2018-01-28', 'yyyy-MM-dd')); -- no output select `id`, `type`, COUNT(1) as event_cnt, session_start(`date`, interval '1' DAY) as ss, session_end(`date`, interval '1' DAY) as se from events group by `id`, `type`, session(`date`, interval '1' DAY); {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)