Fix flipped conditional in SimpleDoFnRunner
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f0c8d30d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f0c8d30d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f0c8d30d Branch: refs/heads/gearpump-runner Commit: f0c8d30d61c631fea642becde38b9cc52e873b5e Parents: 043ebec Author: Kenneth Knowles <[email protected]> Authored: Fri Oct 21 13:53:53 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Sun Oct 23 21:04:17 2016 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f0c8d30d/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 1cf56a6..dec9905 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 @@ -125,11 +125,11 @@ public class SimpleDoFnRunner<InputT, OutputT> implements DoFnRunner<InputT, Out @Override public void processElement(WindowedValue<InputT> compressedElem) { if (observesWindow) { - invokeProcessElement(compressedElem); - } else { for (WindowedValue<InputT> elem : compressedElem.explodeWindows()) { invokeProcessElement(elem); } + } else { + invokeProcessElement(compressedElem); } }
