[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek updated BEAM-270: ---------------------------------- Issue Type: Sub-task (was: Improvement) Parent: BEAM-258 > Use WindowedValue in Flink Batch > -------------------------------- > > Key: BEAM-270 > URL: https://issues.apache.org/jira/browse/BEAM-270 > Project: Beam > Issue Type: Sub-task > Components: runner-flink > Reporter: Aljoscha Krettek > > Right now, Flink Batch execution does not use {{WindowedValue}} internally, > this means that all programs that interact with timestamps/windows will not > work. We should just internally wrap everything in {{WindowedValue}} as we do > in Flink Streaming. -- This message was sent by Atlassian JIRA (v6.3.4#6332)