Change Window Size during runtime

[Rad Rad]

Hi All,

I have one stream is consumed by FlinkKafkaConsumer which will be joined
with another stream for defined window size such as
Time.milliseconds(10000). How can I change window size during runtime to
Time.milliseconds(20000)?


Stream1.join(Stream2)
                                .where(new SingleValueSensorKeySelector())
                                .equalTo(new GPSKeySelector())
                                .window(TumblingEventTimeWindows.of(Time.milliseconds(10000)))
                                .apply(joinStreamFunc).addSink(kafkaProducer);
         



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Chesnay Schepler]

You can't change the window size at runtime.

On 03.01.2019 00:54, Rad Rad wrote:

> Hi All,
>
> I have one stream is consumed by FlinkKafkaConsumer which will be joined
> with another stream for defined window size such as
> Time.milliseconds(10000). How can I change window size during runtime to
> Time.milliseconds(20000)?
>
>
> Stream1.join(Stream2)
> .where(new SingleValueSensorKeySelector())
> .equalTo(new GPSKeySelector())
> .window(TumblingEventTimeWindows.of(Time.milliseconds(10000)))
> .apply(joinStreamFunc).addSink(kafkaProducer);
>
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>

[Congxian Qiu]

Hi, Rad 

We can not change the window size during runtime as Chesnay said.  Could you please share the reason why would you want to change the window size during runtime? 

Rad Rad <[hidden email]> 于2019年1月3日周四 上午8:03写道：

Hi All,

I have one stream is consumed by FlinkKafkaConsumer which will be joined
with another stream for defined window size such as
Time.milliseconds(10000). How can I change window size during runtime to
Time.milliseconds(20000)?


Stream1.join(Stream2)
                                .where(new SingleValueSensorKeySelector())
                                .equalTo(new GPSKeySelector())
                                .window(TumblingEventTimeWindows.of(Time.milliseconds(10000)))
                                .apply(joinStreamFunc).addSink(kafkaProducer);




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

--