beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [1/4] incubator-beam git commit: [flink] use exploded WindowValue in FlinkDoFnFunction
Date Fri, 09 Sep 2016 14:03:52 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 817515fe4 -> a96ea98a4


[flink] use exploded WindowValue in FlinkDoFnFunction


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3461ce21
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3461ce21
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3461ce21

Branch: refs/heads/master
Commit: 3461ce21b8b88de18154de777e21dc7af889f2c7
Parents: 26635d7
Author: Maximilian Michels <mxm@apache.org>
Authored: Wed Sep 7 14:49:02 2016 +0200
Committer: Maximilian Michels <mxm@apache.org>
Committed: Wed Sep 7 14:49:02 2016 +0200

----------------------------------------------------------------------
 .../runners/flink/translation/functions/FlinkDoFnFunction.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/3461ce21/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java
----------------------------------------------------------------------
diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java
b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java
index ac5b345..798a23c 100644
--- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java
+++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java
@@ -86,7 +86,7 @@ public class FlinkDoFnFunction<InputT, OutputT>
       // is in only one window
       for (WindowedValue<InputT> value : values) {
         for (WindowedValue<InputT> explodedValue : value.explodeWindows()) {
-          context = context.forWindowedValue(value);
+          context = context.forWindowedValue(explodedValue);
           doFn.processElement(context);
         }
       }


Mime
View raw message