[jira] [Created] (FLINK-31013) SessionWindowAggregation cannot get trigger window using event time

["Jane Chan (Jira)" <ji...@apache.org>]

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)