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 <radhya.sa...@gmail.com> 于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/ > -- Blog:http://www.klion26.com GTalk:qcx978132955 一切随心
