Skip to content

Commit dea4a7c

Browse files
ArunPiduguDDclaude
andcommitted
add changelog fragment for unordered stateless transforms and scheduling pressure metric
Co-Authored-By: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com>
1 parent 75e4750 commit dea4a7c

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
Added a new global configuration option `preserve_ordering_stateless_transforms` (default: `true`) that
2+
controls whether stateless transforms maintain event ordering when processing concurrently. Setting this
3+
to `false` allows concurrent tasks to complete out of order, which can improve throughput in CPU-bound
4+
transform workloads at the cost of ordering guarantees.
5+
6+
Added a new internal metric `estimated_concurrent_transform_scheduling_pressure` that measures the
7+
fraction of in-flight concurrent transform tasks that completed while a new input batch was being
8+
waited on. A value near 1.0 indicates the transform is CPU-bound and may benefit from setting
9+
`preserve_ordering_stateless_transforms: false`.
10+
11+
authors: ArunPiduguDD

0 commit comments

Comments
 (0)