[
https://issues.apache.org/jira/browse/FLINK-31013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31013:
------------------------------
Summary: Session window aggregation cannot trigger window using event time
(was: SessionWindowAggregation cannot get trigger window using event time)
> Session window aggregation cannot 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
> Priority: Major
> 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)
