You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Success/Error Counters: Track successful and failed deserialization attempts (numDeserializeSuccess, numDeserializeError).
Latency Gauges: Measure the time taken for both serialization and deserialization (deserializeTimeLag, serializeTimeLag).
SnapshotState Metrics:
Creation/Error Counters: Monitor the number of snapshots created and errors encountered during snapshot operations (numSnapshotCreate, numSnapshotError).
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).
PeterZh6
changed the title
[Feature][Sort] Added new source metrics for sort-connector-pulsar-v1.15
[Feature][Sort] Add new source metrics for sort-connector-pulsar-v1.15
Oct 14, 2024
Description
Parent Issue: #10961
Added source metrics in the same way as
PostgreSQL-connector
[Feature][Sort] Enhanced source metric instrumentation for InLong Sort Flink Connector #11129 for sort-connector-pulsar-v1.15Key Metric Categories:
Serialization/Deserialization Metrics:
numDeserializeSuccess
,numDeserializeError
).deserializeTimeLag
,serializeTimeLag
).SnapshotState Metrics:
numSnapshotCreate
,numSnapshotError
).NotifyComplete Metrics:
numCompletedSnapshots
).snapshotToCheckpointTimeLag
).Use case
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: