This closes #1325
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fe17ef7f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fe17ef7f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fe17ef7f Branch: refs/heads/master Commit: fe17ef7f8f5a8037d0aeae8841b424cb76e86dcb Parents: f0f4af5 bfa4e4e Author: Thomas Groh <[email protected]> Authored: Fri Nov 11 16:51:37 2016 -0800 Committer: Thomas Groh <[email protected]> Committed: Fri Nov 11 16:51:37 2016 -0800 ---------------------------------------------------------------------- runners/direct-java/pom.xml | 13 ------- .../runners/direct/AggregatorContainer.java | 2 +- .../direct/ExecutorServiceParallelExecutor.java | 41 ++++++++++++-------- .../direct/WatermarkCallbackExecutor.java | 4 +- .../beam/runners/direct/WatermarkManager.java | 4 +- 5 files changed, 32 insertions(+), 32 deletions(-) ----------------------------------------------------------------------
