You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 陈帅 <ca...@gmail.com> on 2019/12/14 10:43:51 UTC
flink如何动态修改窗口大小和类型？
flink目前支不支持动态修改窗口大小和类型呢？例如先是统计5分钟窗口，而后修改成统计10分钟窗口.
Re:flink如何动态修改窗口大小和类型？
Posted by Utopia <ge...@gmail.com>.
不是有 Dynamic gap 吗？
Best regards
Utopia
在 2019年12月18日 +0800 22:34，jingjing bai <ba...@gmail.com>，写道：
> 目前一个任务中，仅支持一种窗口。
> 动态修改本身应该是一个伪需求
> 如果你仅仅是为了方便快速开发，建议你用sql方式去开发，比如自己扩展sql client。
>
>
> LakeShen <sh...@gmail.com> 于2019年12月18日周三 下午2:12写道：
>
> > 使用自定义 Trigger 试试，在 Trigger 中自定义业务触发逻辑。
> >
> > 陈帅 <ca...@gmail.com> 于2019年12月14日周六 下午6:44写道：
> >
> > > flink目前支不支持动态修改窗口大小和类型呢？例如先是统计5分钟窗口，而后修改成统计10分钟窗口.
> > >
> >
Re: flink如何动态修改窗口大小和类型？
Posted by jingjing bai <ba...@gmail.com>.
目前一个任务中，仅支持一种窗口。
动态修改本身应该是一个伪需求
如果你仅仅是为了方便快速开发，建议你用sql方式去开发，比如自己扩展sql client。
LakeShen <sh...@gmail.com> 于2019年12月18日周三 下午2:12写道：
> 使用自定义 Trigger 试试，在 Trigger 中自定义业务触发逻辑。
>
> 陈帅 <ca...@gmail.com> 于2019年12月14日周六 下午6:44写道：
>
> > flink目前支不支持动态修改窗口大小和类型呢？例如先是统计5分钟窗口，而后修改成统计10分钟窗口.
> >
>
Re: Re: flink如何动态修改窗口大小和类型？
Posted by 王双利 <al...@163.com>.
有例子吗？复杂点的是有一个控制窗口大小的控制流connect实现
王双利
发件人： 陈帅
发送时间： 2019-12-18 22:51
收件人： user-zh@flink.apache.org
主题： Re: flink如何动态修改窗口大小和类型？
现实中确实有这类需求，简单点的是元素本身带有窗口大小设置，复杂点的是有一个控制窗口大小的控制流connect实现。
LakeShen <sh...@gmail.com> 于2019年12月18日周三 下午2:12写道：
> 使用自定义 Trigger 试试，在 Trigger 中自定义业务触发逻辑。
>
> 陈帅 <ca...@gmail.com> 于2019年12月14日周六 下午6:44写道：
>
> > flink目前支不支持动态修改窗口大小和类型呢？例如先是统计5分钟窗口，而后修改成统计10分钟窗口.
> >
>
Re: flink如何动态修改窗口大小和类型？
Posted by 陈帅 <ca...@gmail.com>.
现实中确实有这类需求，简单点的是元素本身带有窗口大小设置，复杂点的是有一个控制窗口大小的控制流connect实现。
LakeShen <sh...@gmail.com> 于2019年12月18日周三 下午2:12写道：
> 使用自定义 Trigger 试试，在 Trigger 中自定义业务触发逻辑。
>
> 陈帅 <ca...@gmail.com> 于2019年12月14日周六 下午6:44写道：
>
> > flink目前支不支持动态修改窗口大小和类型呢？例如先是统计5分钟窗口，而后修改成统计10分钟窗口.
> >
>
Re: flink如何动态修改窗口大小和类型？
Posted by LakeShen <sh...@gmail.com>.
使用自定义 Trigger 试试，在 Trigger 中自定义业务触发逻辑。
陈帅 <ca...@gmail.com> 于2019年12月14日周六 下午6:44写道：
> flink目前支不支持动态修改窗口大小和类型呢？例如先是统计5分钟窗口，而后修改成统计10分钟窗口.
>