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/