You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/08/28 17:01:49 UTC
[1/2] beam git commit: Initialize the Coder in DecodeAndEmitDoFn
Repository: beam
Updated Branches:
refs/heads/master ba5c4071d -> e6d5e0887
Initialize the Coder in DecodeAndEmitDoFn
Ensure that the coder is available before it is used
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0cf45438
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0cf45438
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0cf45438
Branch: refs/heads/master
Commit: 0cf454389129fbbe43d03ac3b26368e6d477d126
Parents: ba5c407
Author: Thomas Groh <tg...@google.com>
Authored: Fri Aug 25 16:58:31 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Aug 28 09:59:03 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/runners/dataflow/DataflowRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/0cf45438/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
----------------------------------------------------------------------
diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
index 496681e..afccfca 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@ -1102,7 +1102,7 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob> {
@ProcessElement
public void processElement(ProcessContext context) throws IOException {
for (byte[] element : elements) {
- context.output(CoderUtils.decodeFromByteArray(coder, element));
+ context.output(CoderUtils.decodeFromByteArray(getCoder(), element));
}
}
}
[2/2] beam git commit: Initialize the Coder in DecodeAndEmitDoFn
Posted by lc...@apache.org.
Initialize the Coder in DecodeAndEmitDoFn
This closes #3769
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e6d5e088
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e6d5e088
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e6d5e088
Branch: refs/heads/master
Commit: e6d5e0887643f341ce59d316d381889eb975dd39
Parents: ba5c407 0cf4543
Author: Luke Cwik <lc...@google.com>
Authored: Mon Aug 28 10:01:38 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Aug 28 10:01:38 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/runners/dataflow/DataflowRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------