Repository: beam Updated Branches: refs/heads/master eebff9089 -> dd9abc397
This closes #3353 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dd9abc39 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dd9abc39 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/dd9abc39 Branch: refs/heads/master Commit: dd9abc397c67b47f95414bfd5debb08b7b6a6eaf Parents: eebff90 8a850af Author: Thomas Groh <[email protected]> Authored: Wed Jun 14 10:21:02 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Wed Jun 14 10:21:02 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/CommittedResult.java | 12 ++++----- .../beam/runners/direct/EvaluationContext.java | 26 +++++++++++++++----- .../direct/ExecutorServiceParallelExecutor.java | 9 ++++--- .../beam/runners/direct/WatermarkManager.java | 4 +-- .../runners/direct/CommittedResultTest.java | 17 +++++++------ .../runners/direct/TransformExecutorTest.java | 11 +++++++-- .../runners/direct/WatermarkManagerTest.java | 15 ++++++++--- 7 files changed, 62 insertions(+), 32 deletions(-) ----------------------------------------------------------------------
