This closes #2442
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6aed130c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6aed130c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6aed130c Branch: refs/heads/master Commit: 6aed130cc293cfa30e5ec3eca09d1145eea908a2 Parents: 3178f07 63327dd Author: Aljoscha Krettek <[email protected]> Authored: Tue Apr 25 17:42:26 2017 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Tue Apr 25 17:42:26 2017 +0200 ---------------------------------------------------------------------- .../flink/FlinkPipelineExecutionEnvironment.java | 8 ++++++++ .../beam/runners/flink/FlinkPipelineOptions.java | 13 +++++++++++++ .../apache/beam/runners/flink/PipelineOptionsTest.java | 9 +++++++++ 3 files changed, 30 insertions(+) ----------------------------------------------------------------------
