OK, thanks so much David very helpful.
Sorry for any inconvenience.
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Mazen, questions like this are better suited to the user mailing list.
FYI, this is also being discussed on stackoverflow:
https://stackoverflow.com/questions/63902457/flink-timeout-using-keyedcoprocessfunction-and-order-of-reading-for-flinkkafkaco
Regards,
David
On Wed, Sep 16, 2020 at 9:41 AM
Hey all,
I am using the KeyedCoProcessFunction class in Flink DataStream APIs to
implement a timeout like use case. The scenario is as follows: I have an
input kafka topic and an output Kafka topic, a service reads from the input
topic processes it (for variable amount of time) and then
Hey all,
I am using the KeyedCoProcessFunction class in Flink DataStream APIs to
implement a timeout like use case. The scenario is as follows: I have an
input kafka topic and an output Kafka topic, a service reads from the input
topic processes it (for variable amount of time) and then
Hey all,
I am using the KeyedCoProcessFunction class in Flink DataStream APIs to
implement a timeout like use case. The scenario is as follows: I have an
input kafka topic and an output Kafka topic, a service reads from the input
topic processes it (for variable amount of time) and then
