How to get the Ingestion time of an event when the time characteristic is event-time?

0
votes

I want to evaluate the time costed between an event reaches the system and get finished, and I think getting ingestion time will help, but how to do get it?

1
apache-flink

1 Answers

1
votes

You probably want to use latency tracking. Alternatively, you can add the processing time directly after the source in a chained process function (with Context->TimerService#currentProcessingTime()).