[
https://issues.apache.org/jira/browse/BEAM-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Batkhuyag Batsaikhan closed BEAM-4507.
--------------------------------------
Resolution: Won't Fix
Fix Version/s: 2.5.0
> Objects that have Fixed Window after a Global Window disappear in Directrunner
> ------------------------------------------------------------------------------
>
> Key: BEAM-4507
> URL: https://issues.apache.org/jira/browse/BEAM-4507
> Project: Beam
> Issue Type: Improvement
> Components: runner-direct
> Affects Versions: 2.4.0
> Reporter: Reza ardeshir rokni
> Assignee: Batkhuyag Batsaikhan
> Priority: Major
> Fix For: 2.5.0
>
>
> 1- Create a elements that go into a combinar and then drops into a Keyed
> Global Window, on entry setup a timer.
> Have the OnTime function:
> 1- c.output the original element with a timestamp == to the original timestamp
> 2- Create a new timestamp with element in the next window....
> 2- LOG the output in a DoFn after the keyed state code, you should see all
> the values.
> 3- Now apply a FixedWindow... and then try and log the output.. the original
> elements wont appear, but the new OnTime generated ones will.
>
> Tested in Dataflow runner and things work ok, the direct runner fails.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
