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)); } } }