PeterZh6 opened a new issue, #11355: URL: https://github.com/apache/inlong/issues/11355
### Description ### Description Parent Issue: https://github.com/apache/inlong/issues/10961 Added source metrics in the same way as `PostgreSQL-connector` [[Feature][Sort] Enhanced source metric instrumentation for InLong Sort Flink Connector #11129](https://github.com/apache/inlong/issues/11129) for sort-connector-pulsar-v1.15 ### Key Metric Categories: 1. **Serialization/Deserialization Metrics:** - **Success/Error Counters:** Track successful and failed deserialization attempts (`numDeserializeSuccess`, `numDeserializeError`). - **Latency Gauges:** Measure the time taken for both serialization and deserialization (`deserializeTimeLag`, `serializeTimeLag`). 2. **SnapshotState Metrics:** - **Creation/Error Counters:** Monitor the number of snapshots created and errors encountered during snapshot operations (`numSnapshotCreate`, `numSnapshotError`). 3. **NotifyComplete Metrics:** - **Completed Snapshots Counter:** Track the number of completed checkpoints (`numCompletedSnapshots`). - **Snapshot-to-Checkpoint Latency:** Record the time between snapshot creation and checkpoint completion (`snapshotToCheckpointTimeLag`). ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@inlong.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
