This closes #432
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f5583cfa Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f5583cfa Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f5583cfa Branch: refs/heads/master Commit: f5583cfad6c857d919995edd385adaf0f41fd676 Parents: ffbfc66 eced106 Author: Maximilian Michels <m...@apache.org> Authored: Wed Jun 8 18:04:50 2016 +0200 Committer: Maximilian Michels <m...@apache.org> Committed: Wed Jun 8 18:04:50 2016 +0200 ---------------------------------------------------------------------- .../streaming/FlinkAbstractParDoWrapper.java | 29 +++--- .../beam/runners/flink/PipelineOptionsTest.java | 97 +++++++++++++++++++- 2 files changed, 111 insertions(+), 15 deletions(-) ----------------------------------------------------------------------
