beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Thomas Groh (JIRA)" <j...@apache.org>
Subject [jira] [Created] (BEAM-732) Placing Timers into the global window causes tests to Flake
Date Fri, 07 Oct 2016 22:53:20 GMT
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)

Mime
View raw message