[FLINK] Add support for collecting task metrics
Open
enhancement
- Dominant language
- Scala
- Stars
- 1.6k
- Forks
- 657
- Avg merge
- 2d 21h
- Merged PRs (30d)
- 85
Description
### Description
support to collect task metrics, including
`ByteIn`,
`ByteOut`,
`RecordsIn`,
`RecodsOut`
`Kafka/pulsar CommitOffset succeed`
`Kafka/pulsar CommitOffset failed`
`deserialized failed msg num`
....
### Gluten version
None
Contributor guide
Assessment
This issue has not been assessed yet.