[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117523#comment-16117523
]
Kenneth Knowles commented on BEAM-2671:
---------------------------------------
It is entirely possible that 935c077341de580dddd4b29ffee3926795acf403 could
expose existing bugs in timer handling. In particular, it changes window GC
from being based on the target time of the timer to being based on the
watermark. So it might turn a race condition causing flakiness into a
guaranteed early GC. (I haven't looked more closely yet)
> CreateStreamTest.testFirstElementLate validatesRunner test fails on Spark
> runner
> --------------------------------------------------------------------------------
>
> Key: BEAM-2671
> URL: https://issues.apache.org/jira/browse/BEAM-2671
> Project: Beam
> Issue Type: Bug
> Components: runner-spark
> Reporter: Etienne Chauchot
> Assignee: Jean-Baptiste Onofré
> Fix For: 2.1.0
>
>
> Error message:
> Flatten.Iterables/FlattenIterables/FlatMap/ParMultiDo(Anonymous).out0:
> Expected: iterable over [] in any order
> but: Not matched: "late"
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
