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.
MetricsScopeDescriptionType
in
FunctionThe number of incoming messages.Counter
inRate
FunctionThe average number of incoming messages per second.Meter
outLocal
FunctionThe number of messages sent to a function on the same task slot.Counter
outLocalRate
FunctionThe average number of messages sent to a function on the same task slot per second.Meter
outRemote
FunctionThe number of messages sent to a function on a different task slot.Counter
outRemoteRate
FunctionThe average number of messages sent to a function on a different task slot per second.Meter
outEgress
FunctionThe number of messages sent to an egress.Counter
inflightAsyncOps
FunctionThe number of uncompleted asynchronous operations.Counter
numBackLog
Remote FunctionThe number of pending messages to be sent.Counter
numBlockedAddress
Remote FunctionThe number of addresses that are currently under back pressure.Counter
remoteInvocationFailures
Remote FunctionThe number of failed attempts to invoke a function remotely.Counter
remoteInvocationFailuresRate
Remote FunctionThe average number of failed attempts to invoke a function remotely.Meter
remoteInvocationLatency
Remote FunctionA distribution of remote function invocation latencies.Histogram
feedback.produced
OperatorThe number of messages read from the feedback channel.Counter
feedback.producedRate
OperatorThe average number of messages read from the feedback channel per second.Meter
inflightAsyncOps
OperatorThe total number of uncompleted asynchronous operations (across all function types).Counter