I have a question around event timestamps after a flatMap transformation, I
am using the event time time characteristic. I have two streams entering a
CoFlatMap. Stream A simply updates state in that CoFlatMap and does not
output any events. Stream B inserts events of type B which then output a
thi
Hi,
I have two questions around Flink deployment. I have done some research but
I wanted to confirm my conclusions.
1) Is it possible to do a live upgrade of a Flink cluster from one version
to the next without having to take down the entire cluster? (Imagining a
rolling deploy where we only take
