SAMZA-2801: fix the case when waterrmark is not aggregated when quorum is not met#1707

Merged

xinyuiscool merged 9 commits intoapache:masterfrom xinyuiscool:watermark-update2

Aug 21, 2024

+58-14

Commits on Aug 13, 2024

Initial impl to add task watermark idle time
Xinyu Liu
committed
Make default task.watermark.idle.ms to be -1
Xinyu Liu
committed

Commits on Aug 14, 2024

Add handling for skipping tasks not emitting watermarks from the beginning
Xinyu Liu
committed
Address feedback
Xinyu Liu
committed

Commits on Aug 15, 2024

Add logic to establish quorum in case of idle tasks
Xinyu Liu
committed

Commits on Aug 16, 2024

Add logging for quorum count update
Xinyu Liu
committed

Commits on Aug 21, 2024

Fix the watermark advance when quarum is not reached
Xinyu Liu
committed
Merge branch 'master' into watermark-update2
Xinyu Liu
committed
Fix typo
Xinyu Liu
committed