Hi all
i have 2 pipelines:
A. receives information from kafka and "holds" that info
B. a pipeline which is triggered by a scheduler and every x minutes should
send the info i received in pipeline A to another kafka topic

As i understood i cannot use the flink state for this since these are
different pipelines/operators..
is there a way to implement such a case in Flink itself without using any
external application like redis or db?

Thanks
Sigalit

Reply via email to