This documentation is for an unreleased version of Apache Flink Stateful Functions. We recommend you use the latest stable version.
Metrics
Metrics #
Stateful Functions includes a number of SDK specific metrics.
Along with the standard metric scopes, Stateful Functions supports Function Scope which one level below operator scope.
metrics.scope.function
- Default: <host>.taskmanager.<tm_id>.<job_name>.<operator_name>.<subtask_index>.<function_namespace>.<function_name>
- Applied to all metrics that were scoped to a function.
| Metrics | Scope | Description | Type |
|---|---|---|---|
in |
Function | The number of incoming messages. | Counter |
inRate |
Function | The average number of incoming messages per second. | Meter |
outLocal |
Function | The number of messages sent to a function on the same task slot. | Counter |
outLocalRate |
Function | The average number of messages sent to a function on the same task slot per second. | Meter |
outRemote |
Function | The number of messages sent to a function on a different task slot. | Counter |
outRemoteRate |
Function | The average number of messages sent to a function on a different task slot per second. | Meter |
outEgress |
Function | The number of messages sent to an egress. | Counter |
inflightAsyncOps |
Function | The number of uncompleted asynchronous operations. | Counter |
numBackLog |
Remote Function | The number of pending messages to be sent. | Counter |
numBlockedAddress |
Remote Function | The number of addresses that are currently under back pressure. | Counter |
remoteInvocationFailures |
Remote Function | The number of failed attempts to invoke a function remotely. | Counter |
remoteInvocationFailuresRate |
Remote Function | The average number of failed attempts to invoke a function remotely. | Meter |
remoteInvocationLatency |
Remote Function | A distribution of remote function invocation latencies. | Histogram |
feedback.produced |
Operator | The number of messages read from the feedback channel. | Counter |
feedback.producedRate |
Operator | The average number of messages read from the feedback channel per second. | Meter |
inflightAsyncOps |
Operator | The total number of uncompleted asynchronous operations (across all function types). | Counter |