This closes #3263
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4884d486 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4884d486 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4884d486 Branch: refs/heads/master Commit: 4884d486795e29a13a0765b11fb844d5257c468a Parents: 19c33df 5780fc5 Author: Dan Halperin <[email protected]> Authored: Wed May 31 11:36:17 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed May 31 11:36:17 2017 -0700 ---------------------------------------------------------------------- .../runners/flink/translation/functions/FlinkDoFnFunction.java | 6 ++++-- .../flink/translation/functions/FlinkStatefulDoFnFunction.java | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
