You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
tisonet
changed the title
PubSubReader detects idle topic and propagates it to watermark estimator
PubSubReader should detect idle topic and propagate it to watermark estimator
Jun 5, 2020
PubSubReader doesn't fulfil the complete contract of Watermark estimator. The
idle()
method is not called when topic doesn't have more data.Reader has to detect idle topic and propagates this signal to watermark estimator.
The text was updated successfully, but these errors were encountered: