Re: Change Window Size during runtime

[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  于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(1). How can I change window size during runtime to
> Time.milliseconds(2)?
>
>
> Stream1.join(Stream2)
> .where(new SingleValueSensorKeySelector())
> .equalTo(new GPSKeySelector())
>
> .window(TumblingEventTimeWindows.of(Time.milliseconds(1)))
>
> .apply(joinStreamFunc).addSink(kafkaProducer);
>
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>


-- 
Blog:http://www.klion26.com
GTalk:qcx978132955
一切随心

Re: Change Window Size during runtime

[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(1). How can I change window size during runtime to
Time.milliseconds(2)?


Stream1.join(Stream2)
.where(new SingleValueSensorKeySelector())
.equalTo(new GPSKeySelector())

.window(TumblingEventTimeWindows.of(Time.milliseconds(1)))
.apply(joinStreamFunc).addSink(kafkaProducer);




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