Stalled

Stalled (stalled)

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

Transform json

Minimal example

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

JSON

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

Contents

• Minimal example

• Fields

• General

• Behaviour

• Input

• Persistence

• Diagnostics

Fields

Field	Type	Required	Description
marker Behaviour	string	✅	Field/value pair (e.g. “status:stalled”) stamped onto generated events.
timeout Behaviour	duration (string)	✅	Duration to wait before flagging the stream as stalled (e.g. ”30s”).
description General	string		Describe this step.
condition General	lua-expression (string)		Only run this action when the Lua condition evaluates to true. Examples: 2 * count()
use-document-marker Behaviour	boolean (bool)		Emit document markers instead of JSON payloads.
input-field Input	field (string)		Only consider events grouped by the value of this field. Examples: data_field
time-field Input	field (string)		Field containing event time used for timeout calculations. Examples: data_field
save-file Persistence	path (string)		Optional file where stall state is written for recovery. Examples: /path/to/file, c:\users\joe\data\file.txt
ignore-warning Diagnostics	boolean (bool)		Suppress warnings when the timeout is very low or configuration is incomplete.

General

Show fields

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()

Behaviour

Show fields

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

Input

Show fields

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

Show fields

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

Diagnostics

Show fields

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