Hi Yubin, We implement it in this manner. For every record, we define several time fields. When the record first enters the system, set one field to current time. After several complex calculation operator, set another field to currentTime. Just calculate the difference between the two values.
Hope this will help. Best Regards, Lei On Wed, Jul 31, 2024 at 5:06 PM Yubin Li <lyb5...@gmail.com> wrote: > Hi everyone, > > We are focusing on improving observability for Flink, we have a vision > to make the latency of every business stream record observable, is > there any idea to implement the feature? looking forward to your > suggestions! >
