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 <mxm@apache.org>
Authored: Wed Jun 8 18:04:50 2016 +0200
Committer: Maximilian Michels <mxm@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(-)
----------------------------------------------------------------------
|