You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/05/18 20:08:39 UTC
[39/50] [abbrv] beam git commit: Fixes an accidentally found bug in
SimpleDoFnRunner
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/gearpump-runner
Commit: 24179494a116cfde1c1462dd3125ba558d72f494
Parents: 6127f53
Author: Eugene Kirpichov <ki...@google.com>
Authored: Fri May 12 11:19:38 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
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(