This closes #1644
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5ebbd500 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5ebbd500 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5ebbd500 Branch: refs/heads/master Commit: 5ebbd500c1548a6a53a5fbce8b0b3dd67d735d1e Parents: d624d3b 55f0495 Author: Sela <ans...@paypal.com> Authored: Fri Dec 16 11:47:06 2016 +0200 Committer: Sela <ans...@paypal.com> Committed: Fri Dec 16 11:47:06 2016 +0200 ---------------------------------------------------------------------- .../runners/apex/translation/operators/ApexParDoOperator.java | 2 +- .../src/main/java/org/apache/beam/runners/core/DoFnRunners.java | 1 - .../java/org/apache/beam/runners/core/SimpleDoFnRunner.java | 1 - .../java/org/apache/beam/runners/core/SimpleOldDoFnRunner.java | 1 - .../org/apache/beam/runners/direct/AggregatorContainer.java | 2 +- .../flink/translation/wrappers/streaming/DoFnOperator.java | 3 ++- .../apache/beam/runners/spark/aggregators/SparkAggregators.java | 5 +++-- 7 files changed, 7 insertions(+), 8 deletions(-) ----------------------------------------------------------------------
