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(-) ----------------------------------------------------------------------