Hi,
In my flink operators, I need to connect to an external service to update
state. I was thinking that the updates to the external service can be
synchronized via checkpoint barriers.
The topology of the stream is a source, then a single stage of operator
replicas handling different partitions,
Hello,
We are creating two data streams in our Flink application. Both of them are
then formed into two Tables. The first data stream has a watermark delay of
24 hours while the second stream has a watermark delay of 60 minutes. The
watermark used is of BoundedOutOfOrderness strategy and uses a pa
