You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2016/11/12 00:53:08 UTC
[2/2] incubator-beam git commit: This closes #1325
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 <tg...@google.com>
Authored: Fri Nov 11 16:51:37 2016 -0800
Committer: Thomas Groh <tg...@google.com>
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(-)
----------------------------------------------------------------------