Observability around Flink Pipeline/stateful functions

[Deepak Sharma <de...@gmail.com>]

@dev@spark.apache.org <de...@spark.apache.org> @user <us...@flink.apache.org>
I am looking for an example around the observability framework for Apache
Flink pipelines.
This could be message tracing across multiple flink pipelines or query on
the past state of a message that was processed by any flink pipeline.
If anyone has done similar work and can share any
pointers(blogs/books/writeup) , it would really help.

Thanks a lot in advance.

--Deepak