Fixes an accidentally found bug in SimpleDoFnRunner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/24179494 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/24179494 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/24179494 Branch: refs/heads/jstorm-runner Commit: 24179494a116cfde1c1462dd3125ba558d72f494 Parents: 6127f53 Author: Eugene Kirpichov <[email protected]> Authored: Fri May 12 11:19:38 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Tue May 16 11:55:43 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/24179494/runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java ---------------------------------------------------------------------- diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java index 7ca305e..65384da 100644 --- a/runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java +++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java @@ -215,7 +215,7 @@ public class SimpleDoFnRunner<InputT, OutputT> implements DoFnRunner<InputT, Out private DoFnStartBundleContext<InputT, OutputT> createStartBundleContext( DoFn<InputT, OutputT> fn, DoFnContext<InputT, OutputT> context) { - return new DoFnStartBundleContext<>(this.fn, this.context); + return new DoFnStartBundleContext<>(fn, context); } private DoFnFinishBundleContext<InputT, OutputT> createFinishBundleContext(
