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

Posted to user@flink.apache.org by antonio saldivar <an...@gmail.com> on 2018/07/20 18:59:13 UTC

working with flink Session Windows

Hello

I am building an app but for this UC I want to test with session windows
and I am not sure if this will be expensive for the compute resources
because the gap will be 10 mins, 20 mins 60 mins because I want to trigger
an alert if the element reaches some thresholds within those periods of
time.

flink version 1.4.2

Thank you
Best Regards
Antonio Saldivar

Re: working with flink Session Windows

Posted by antonio saldivar <an...@gmail.com>.

Hello

Actually I evaluate my WindowFunction with a trigger alert, having
something like below code (testing with 2 different windows), expecting 5K
elements per second arriving


SingleOutputStreamOperator<String> windowedElem = element

.keyBy("id")

.timeWindow(Time.seconds(120))

//     .window(EventTimeSessionWindows.withGap(Time.minutes(20)))

.trigger(new AlertTrigger(env.getStreamTimeCharacteristic())

.aggregate(new EleAggregator(), new EleWindowFn())


El vie., 20 jul. 2018 a las 21:23, Hequn Cheng (<ch...@gmail.com>)
escribió:

> Hi antonio,
>
> I think it worth a try to test the performance in your scenario, since job
> performance can be affected by a number of factors(say your WindowFunction).
>
> Best, Hequn
>
> On Sat, Jul 21, 2018 at 2:59 AM, antonio saldivar <an...@gmail.com>
> wrote:
>
>> Hello
>>
>> I am building an app but for this UC I want to test with session windows
>> and I am not sure if this will be expensive for the compute resources
>> because the gap will be 10 mins, 20 mins 60 mins because I want to trigger
>> an alert if the element reaches some thresholds within those periods of
>> time.
>>
>> flink version 1.4.2
>>
>> Thank you
>> Best Regards
>> Antonio Saldivar
>>
>
>

Re: working with flink Session Windows

Posted by Hequn Cheng <ch...@gmail.com>.

Hi antonio,

I think it worth a try to test the performance in your scenario, since job
performance can be affected by a number of factors(say your WindowFunction).

Best, Hequn

On Sat, Jul 21, 2018 at 2:59 AM, antonio saldivar <an...@gmail.com>
wrote:

> Hello
>
> I am building an app but for this UC I want to test with session windows
> and I am not sure if this will be expensive for the compute resources
> because the gap will be 10 mins, 20 mins 60 mins because I want to trigger
> an alert if the element reaches some thresholds within those periods of
> time.
>
> flink version 1.4.2
>
> Thank you
> Best Regards
> Antonio Saldivar
>