Skip to content

Commit 83eeb23

Browse files
authored
fix: add idleness to stream-sorter example (#280)
Signed-off-by: Vigith Maurice <[email protected]>
1 parent fe0bd4e commit 83eeb23

File tree

1 file changed

+6
-0
lines changed
  • packages/pynumaflow/examples/accumulator/streamsorter

1 file changed

+6
-0
lines changed

packages/pynumaflow/examples/accumulator/streamsorter/pipeline.yaml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,12 @@ metadata:
55
spec:
66
limits:
77
readBatchSize: 1
8+
watermark:
9+
maxDelay: 5s
10+
idleSource:
11+
incrementBy: 1s
12+
stepInterval: 1s
13+
threshold: 5s
814
vertices:
915
- name: http-one
1016
scale:

0 commit comments

Comments
 (0)