Hi， 这个输出是retract的是by design的，你可以自己改造下sink，来输出你想要的结果。 fast emit是按照处理时间来提前输出的。比如某个key下面来了第一条数据之后，开始设置一个固定周期的定时，如果下个周期聚合结果有发生变化，则输出。
flink小猪 <[email protected]> 于2020年3月28日周六 下午8:25写道： > > > > 感谢您的回复，我试了一下，的确通过您说的这种方式，可以得到一个retract流的数据。换一个场景 > 我需要每小时计算当天的交易额（例如两点到了，我应该输出从0点到2点的总交易额）我想获得如下结果： > 2020-03-28T01:00 100 > 2020-03-28T02:00 280 > .... > 2020-03-28T23:00 18000 > 2020-03-28T00:00 19520 > 2020-03-29T01:00 120 > 2020-03-29T01:00 230 > 我应该获得是一个不断append的数据流，而不是retract数据流。 > 并且设置提前发射的事件，flink应该是选取的处理时间而不是事件时间？ > > > > > > > > > 在 2020-03-27 15:23:39，"Benchao Li" <[email protected]> 写道： > >Hi， > > > >对于第二个场景，可以尝试一下fast emit： > >table.exec.emit.early-fire.enabled = true > >table.exec.emit.early-fire.delay = 5min > > > >PS： > >1. 这个feature并没有在官方文档里面写出来，目前应该是一个实验性质的feature > >2. window加了emit之后，会由原来输出append结果变成输出retract结果 > > > >Jingsong Li <[email protected]> 于2020年3月27日周五 下午2:51写道： > > > >> Hi, > >> > >> For #1： > >> 创建级联的两级window： > >> - 1分钟窗口 > >> - 5分钟窗口，计算只是保存数据，发送明细数据结果 > >> > >> Best, > >> Jingsong Lee > >> > > > > > >-- > > > >Benchao Li > >School of Electronics Engineering and Computer Science, Peking University > >Tel:+86-15650713730 > >Email: [email protected]; [email protected] > -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: [email protected]; [email protected]
