[BEAM-732] Placing Timers into the global window causes tests to Flake

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.3.0-incubating
• Component/s: sdk-java-core
• Labels: Done
• Assignee: Thomas Groh
• Reporter: Thomas Groh
• Created: 07/Oct/16 22:52
• Updated: 06/Oct/20 21:52
• Resolved: 11/Oct/16 22:45

Description

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

Issue Links

• links to: GitHub Pull Request #1069