[
https://issues.apache.org/jira/browse/BEAM-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía resolved BEAM-2409.
--------------------------------
Fix Version/s: 2.19.0
Not applicable
Resolution: Fixed
> Spark runner produces exactly twice the number of results in streaming mode
> when use triggers to re-window results on global window.
> ------------------------------------------------------------------------------------------------------------------------------------
>
> Key: BEAM-2409
> URL: https://issues.apache.org/jira/browse/BEAM-2409
> Project: Beam
> Issue Type: Bug
> Components: runner-spark
> Affects Versions: 2.0.0
> Reporter: Ismaël Mejía
> Priority: Major
> Labels: triaged
> Fix For: Not applicable, 2.19.0
>
>
> This can be tested with Nexmark query 6. Sorry I don’t have a smaller test
> case than this, but I think the part of the pipeline that produces the result
> is this one.
> {code:java}
> .apply(
> Window.<KV<Long, Bid>>into(new GlobalWindows())
>
> .triggering(Repeatedly.forever(AfterPane.elementCountAtLeast(1)))
> .accumulatingFiredPanes()
> .withAllowedLateness(Duration.ZERO))
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
