This is an automated email from the ASF dual-hosted git repository.
xinyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
from 50280c60e SAMZA-2801: Support excluding tasks from watermark
computation when exceeding idle time (#1705)
add 3cb57c227 SAMZA-2801: fix the case when waterrmark is not aggregated
when quorum is not met (#1707)
No new revisions were added by this update.
Summary of changes:
.../samza/operators/impl/WatermarkMetrics.java | 8 +++++
.../samza/operators/impl/WatermarkStates.java | 30 ++++++++++---------
.../samza/operators/impl/TestWatermarkStates.java | 34 +++++++++++++++++++++-
3 files changed, 58 insertions(+), 14 deletions(-)
