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(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/