Fix binding of aggregator delegation in DoFnAdapters
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2ab955d5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2ab955d5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2ab955d5 Branch: refs/heads/gearpump-runner Commit: 2ab955d5501c87adea3fd17ad5dd1ad73be13364 Parents: 4e185d0 Author: Kenneth Knowles <[email protected]> Authored: Fri Oct 21 12:44:47 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Sun Oct 23 21:04:17 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2ab955d5/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java index 0b0d207..ca724cd 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnAdapters.java @@ -278,6 +278,7 @@ public class DoFnAdapters { private ContextAdapter(DoFn<InputT, OutputT> fn, OldDoFn<InputT, OutputT>.Context context) { fn.super(); this.context = context; + super.setupDelegateAggregators(); } @Override
