Thomas Groh created BEAM-732:
--------------------------------
Summary: Placing Timers into the global window causes tests to
Flake
Key: BEAM-732
URL: https://issues.apache.org/jira/browse/BEAM-732
Project: Beam
Issue Type: Bug
Reporter: Thomas Groh
Assignee: Thomas Groh
When timers are delivered in the global window rather than in empty windows,
the fact that they may share a timestamp with pending elements causes the
pending elements to be removed from the collection of pending elements,
allowing the watermark to advance inappropriately.
Only remove elements that have become pending. Use a comparator that compares
different elements as nonequal to do so.
See WatermarkManager.AppliedPTransformInputWatermark
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
