[jira] (BEAM-1346) Drop Late Data in ReduceFnRunner

[Aljoscha Krettek (JIRA)]

Title: Message Title

Aljoscha Krettek created an issue   Beam / BEAM-1346 Drop Late Data in ReduceFnRunner Issue Type: Bug Affects Versions: 0.5.0 Assignee: Kenneth Knowles Components: runner-core Created: 30/Jan/17 11:39 Priority: Major Reporter: Aljoscha Krettek I think these two commits recently broke late-data dropping for the Flink Runner (and maybe for other runners as well): https://github.com/apache/beam/commit/2b26ec8 https://github.com/apache/beam/commit/8989473 It boils down to the LateDataDroppingDoFnRunner not being used anymore because DoFnRunners.lateDataDroppingRunner() is not called anymore when a DoFn is a ReduceFnExecutor (because that interface was removed). Maybe we should think about dropping late data in another place, my suggestion is ReduceFnRunner but that's open for discussion. Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)