flink如何动态修改窗口大小和类型?

classic Classic list List threaded Threaded
6 messages Options
Reply | Threaded
Open this post in threaded view
|

flink如何动态修改窗口大小和类型?

陈帅
flink目前支不支持动态修改窗口大小和类型呢?例如先是统计5分钟窗口,而后修改成统计10分钟窗口.
Reply | Threaded
Open this post in threaded view
|

Re: flink如何动态修改窗口大小和类型?

LakeShen
使用自定义 Trigger 试试,在 Trigger 中自定义业务触发逻辑。

陈帅 <[hidden email]> 于2019年12月14日周六 下午6:44写道:

> flink目前支不支持动态修改窗口大小和类型呢?例如先是统计5分钟窗口,而后修改成统计10分钟窗口.
>
Reply | Threaded
Open this post in threaded view
|

Re: flink如何动态修改窗口大小和类型?

jingjing bai
目前一个任务中,仅支持一种窗口。
动态修改本身应该是一个伪需求
如果你仅仅是为了方便快速开发,建议你用sql方式去开发,比如自己扩展sql client。


LakeShen <[hidden email]> 于2019年12月18日周三 下午2:12写道:

> 使用自定义 Trigger 试试,在 Trigger 中自定义业务触发逻辑。
>
> 陈帅 <[hidden email]> 于2019年12月14日周六 下午6:44写道:
>
> > flink目前支不支持动态修改窗口大小和类型呢?例如先是统计5分钟窗口,而后修改成统计10分钟窗口.
> >
>
Reply | Threaded
Open this post in threaded view
|

Re: flink如何动态修改窗口大小和类型?

Utopia
不是有 Dynamic gap 吗?

Best  regards
Utopia
在 2019年12月18日 +0800 22:34,jingjing bai <[hidden email]>,写道:

> 目前一个任务中,仅支持一种窗口。
> 动态修改本身应该是一个伪需求
> 如果你仅仅是为了方便快速开发,建议你用sql方式去开发,比如自己扩展sql client。
>
>
> LakeShen <[hidden email]> 于2019年12月18日周三 下午2:12写道:
>
> > 使用自定义 Trigger 试试,在 Trigger 中自定义业务触发逻辑。
> >
> > 陈帅 <[hidden email]> 于2019年12月14日周六 下午6:44写道:
> >
> > > flink目前支不支持动态修改窗口大小和类型呢?例如先是统计5分钟窗口,而后修改成统计10分钟窗口.
> > >
> >
Reply | Threaded
Open this post in threaded view
|

Re: flink如何动态修改窗口大小和类型?

陈帅
In reply to this post by LakeShen
现实中确实有这类需求,简单点的是元素本身带有窗口大小设置,复杂点的是有一个控制窗口大小的控制流connect实现。

LakeShen <[hidden email]> 于2019年12月18日周三 下午2:12写道:

> 使用自定义 Trigger 试试,在 Trigger 中自定义业务触发逻辑。
>
> 陈帅 <[hidden email]> 于2019年12月14日周六 下午6:44写道:
>
> > flink目前支不支持动态修改窗口大小和类型呢?例如先是统计5分钟窗口,而后修改成统计10分钟窗口.
> >
>
Reply | Threaded
Open this post in threaded view
|

Re: Re: flink如何动态修改窗口大小和类型?

王双利
有例子吗?复杂点的是有一个控制窗口大小的控制流connect实现



王双利
 
发件人: 陈帅
发送时间: 2019-12-18 22:51
收件人: [hidden email]
主题: Re: flink如何动态修改窗口大小和类型?
现实中确实有这类需求,简单点的是元素本身带有窗口大小设置,复杂点的是有一个控制窗口大小的控制流connect实现。
 
LakeShen <[hidden email]> 于2019年12月18日周三 下午2:12写道:
 
> 使用自定义 Trigger 试试,在 Trigger 中自定义业务触发逻辑。
>
> 陈帅 <[hidden email]> 于2019年12月14日周六 下午6:44写道:
>
> > flink目前支不支持动态修改窗口大小和类型呢?例如先是统计5分钟窗口,而后修改成统计10分钟窗口.
> >
>