This closes #795
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c584b37b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c584b37b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c584b37b Branch: refs/heads/master Commit: c584b37b8ac4e863bad83a766b6871ccc7135334 Parents: 2b5c6bc acf71d3 Author: Kenneth Knowles <[email protected]> Authored: Fri Aug 5 10:40:17 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Fri Aug 5 10:40:17 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/direct/EvaluationContext.java | 14 ++++++--- .../direct/ExecutorServiceParallelExecutor.java | 5 ++-- .../beam/runners/direct/TransformExecutor.java | 2 +- .../beam/runners/direct/DirectRunnerTest.java | 31 ++++++++++++++++++++ 4 files changed, 44 insertions(+), 8 deletions(-) ----------------------------------------------------------------------
