Github user HeartSaVioR commented on the issue:
https://github.com/apache/spark/pull/21622
I think we may want to add metrics regarding sources and sinks as well, but
the format of offset information or other metadata information can be different
between sources and sinks.
Not sure about more preferred approach: 1. define general format of
information for source/sink 2. let individual source/sink manage metric as well.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
