This closes #3988: [BEAM-3052] ReduceFnRunner: Do not manage EOW hold or timer, set GC hold and timer always
ReduceFnRunner: Do not manage EOW hold or timer, set GC hold and timer always Truncate the very last fixed window if it goes beyond representable time Tidy a troublesome TestStreamTest Fix expectations in CombineTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a5254e73 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a5254e73 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a5254e73 Branch: refs/heads/tez-runner Commit: a5254e730065d8b15899b094ee54011797fffaa1 Parents: 219b9ca 9c994ca Author: Kenneth Knowles <k...@apache.org> Authored: Mon Nov 13 15:03:37 2017 -0800 Committer: Kenneth Knowles <k...@apache.org> Committed: Mon Nov 13 15:03:37 2017 -0800 ---------------------------------------------------------------------- .../beam/runners/core/ReduceFnRunner.java | 72 ++---- .../apache/beam/runners/core/WatermarkHold.java | 221 +++---------------- .../beam/runners/core/LateDataUtilsTest.java | 2 +- .../beam/runners/core/ReduceFnRunnerTest.java | 191 ++++++++++++---- .../sdk/transforms/windowing/FixedWindows.java | 24 +- .../apache/beam/sdk/testing/TestStreamTest.java | 25 ++- .../apache/beam/sdk/transforms/CombineTest.java | 2 +- .../transforms/windowing/FixedWindowsTest.java | 12 + 8 files changed, 246 insertions(+), 303 deletions(-) ----------------------------------------------------------------------