You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Caizhi Weng <ts...@gmail.com> on 2021/08/02 02:13:18 UTC

Re: Over Window Aggregation Tuning

Hi!

As the state grows the processing speed will slow down a bit. Which state
backend are you using? Is mini batch enabled[1]?

[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/config/#table-exec-mini-batch-enabled

Wanghui (HiCampus) <wa...@huawei.com> 于2021年7月30日周五 下午3:59写道：

> Hi :
>
> When I use Over Window Aggregation,windows size is 1 hour,I find the
> processing speed decreases over time. How can I tuning the over window?
>
> Best regards
>
> Hui Wang
>
>
>

Re: Over Window Aggregation Tuning

Posted by JING ZHANG <be...@gmail.com>.

Hi Wanghui, Caizhi
AFAIK, over window doesn't support mini batch optimization yet.

Caizhi Weng <ts...@gmail.com> 于2021年8月2日周一 上午10:20写道：

> Hi!
>
> As the state grows the processing speed will slow down a bit. Which state
> backend are you using? Is mini batch enabled[1]?
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/config/#table-exec-mini-batch-enabled
>
> Wanghui (HiCampus) <wa...@huawei.com> 于2021年7月30日周五 下午3:59写道：
>
>> Hi :
>>
>> When I use Over Window Aggregation,windows size is 1 hour,I find the
>> processing speed decreases over time. How can I tuning the over window?
>>
>> Best regards
>>
>> Hui Wang
>>
>>
>>
>