Stalled

Stalled (stalled)

Emit stall markers when no matching events arrive within the configured timeout.

Stateful Transform json

Minimal example

actions:
  - stalled:
      marker: ~
      timeout: ""

JSON

{
  "actions": [
    {
      "stalled": {
        "marker": null,
        "timeout": ""
      }
    }
  ]
}

Contents

• Minimal example

• Behaviour

• Diagnostics

• General

• Input

• Persistence

A ✓ marks a field that accepts a context variable such as {{ VARIABLE }}.

Behaviour

Behaviour

Field	Type	Required	Description
marker	string	✅	Field/value pair (e.g. “status:stalled”) stamped onto generated events.
use-document-marker ✓	boolean (bool)		Emit document markers instead of JSON payloads. Default: false
timeout	duration (string)	✅	Duration to wait before flagging the stream as stalled (e.g. “30s”).

Diagnostics

Diagnostics

Field	Type	Required	Description
ignore-warning ✓	boolean (bool)		Suppress warnings when the timeout is very low or configuration is incomplete. Default: false

General

General

Field	Type	Required	Description
description	string		Describe this step.
condition	lua-expression (string)		Only run this action when the Lua condition evaluates to true. Examples: 2 * count()

Input

Input

Field	Type	Required	Description
input-field	field (string)		Only consider events grouped by the value of this field. Examples: data_field
time-field	field (string)		Field containing event time used for timeout calculations. Examples: data_field

Persistence

Persistence

Field	Type	Required	Description
save-file	path (string)		Optional file where stall state is written for recovery. Examples: /path/to/file, c:\users\joe\data\file.txt