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

[Amit Sela (JIRA)]

Title: Message Title

Amit Sela commented on BEAM-1346   Re: Drop Late Data in ReduceFnRunner For the Spark runner, my (endless..) WIP branch doesn't use DoFnRunner, but adopts the DirectRunner approach by dropping late data before processing the elements: https://github.com/amitsela/beam/blob/beam-model-streaming/runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/StateSpecFunctions.java#L228. The implementation itself is a copy of DirectRunner code (with Thomas' blessing) and could be pulled to the runner API utils. But this is not on Master yet, so the Spark runner is not affected anyway. Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)