beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [42/50] beam git commit: This closes #3425: Fix processing time timer handling in ReduceFnRunner
Date Fri, 23 Jun 2017 03:05:08 GMT
This closes #3425: Fix processing time timer handling in ReduceFnRunner

  Add tests for corner cases of processing time timers
  Add test reproducing BEAM-2505, ignored
  Do not GC windows based on processing time timer!
  Drop late data in ReduceFnTester
  ReduceFnTester assertion for windows that have data buffered
  ReduceFnTester can advance clocks without firing timers
  Tidy LateDataDroppingDoFnRunner
  Add window matcher for pane info


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7645c44b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7645c44b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7645c44b

Branch: refs/heads/gearpump-runner
Commit: 7645c44b9bae9a77192fbe6744918cfb95ca1a3a
Parents: 5506be8 d2b384a
Author: Kenneth Knowles <klk@google.com>
Authored: Thu Jun 22 15:41:02 2017 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Thu Jun 22 15:41:02 2017 -0700

----------------------------------------------------------------------
 .../core/LateDataDroppingDoFnRunner.java        |  33 ++---
 .../beam/runners/core/ReduceFnRunner.java       |   3 +-
 .../beam/runners/core/SystemReduceFn.java       |   6 +
 .../beam/runners/core/ReduceFnRunnerTest.java   | 136 ++++++++++++++++++-
 .../beam/runners/core/ReduceFnTester.java       |  48 ++++++-
 .../beam/runners/core/WindowMatchers.java       |  15 ++
 .../beam/sdk/transforms/GroupByKeyTest.java     |  39 ++++++
 7 files changed, 258 insertions(+), 22 deletions(-)
----------------------------------------------------------------------



Mime
View raw message