This closes #3275
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/608a9c45 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/608a9c45 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/608a9c45 Branch: refs/heads/master Commit: 608a9c4590ebd94e53ee1ec7f3ad60bfb4905c11 Parents: e4ef23e 5279409 Author: Pei He <[email protected]> Authored: Tue Jun 20 14:12:55 2017 -0700 Committer: Pei He <[email protected]> Committed: Tue Jun 20 14:12:55 2017 -0700 ---------------------------------------------------------------------- .../FlinkPipelineExecutionEnvironment.java | 2 + .../flink/FlinkStreamingPipelineTranslator.java | 54 -------------------- .../runners/flink/FlinkTransformOverrides.java | 53 +++++++++++++++++++ 3 files changed, 55 insertions(+), 54 deletions(-) ----------------------------------------------------------------------
