This closes #3320
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97957ea0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/97957ea0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/97957ea0 Branch: refs/heads/gearpump-runner Commit: 97957ea0ec1625b0e937a4f3c9ea2bee316d24d4 Parents: 1c6861f b7ae7ec Author: Thomas Groh <tg...@google.com> Authored: Fri Jun 9 10:54:13 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Fri Jun 9 10:54:13 2017 -0700 ---------------------------------------------------------------------- .../runners/flink/FlinkStreamingTransformTranslators.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) ----------------------------------------------------------------------