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