Sam Whittle created BEAM-12254:
----------------------------------
Summary: Nexmark UnboundedReader does not report backlog correctly
Key: BEAM-12254
URL: https://issues.apache.org/jira/browse/BEAM-12254
Project: Beam
Issue Type: Bug
Components: testing-nexmark
Reporter: Sam Whittle
Assignee: Sam Whittle
The reader only reports backlog if it has been initialized by reading elements
and only if rate limiting is on.
However if rate limiting is off and their is a bounded # of elements the
backlog can also be calcualted.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)