You cannot change the size/trigger count while a job is running.
For this to work you will have to take a savepoint, modify the
parameters and reload from the savepoint.
On 11.09.2017 09:27, victor.reut wrote:
Hi,
I want to have an opportunity to update timeWindow size and trigger value in
K
Hi,
I want to have an opportunity to update timeWindow size and trigger value in
KeyedStream dynamically at runtime. For example, I have such a piece of
code:
DataStream stream = env.addSource(new
FlinkKafkaConsumer09<>(TOPIC, new JSONDeserializer(), properties));
Integer numMinutes = .
