This closes #450
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/be05942d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/be05942d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/be05942d Branch: refs/heads/master Commit: be05942da0f09a247e195d1d29513ae40e1a95e0 Parents: 60964b6 a2abc6a Author: Maximilian Michels <[email protected]> Authored: Mon Jun 13 14:57:31 2016 +0200 Committer: Maximilian Michels <[email protected]> Committed: Mon Jun 13 14:57:31 2016 +0200 ---------------------------------------------------------------------- .../wrappers/streaming/FlinkAbstractParDoWrapper.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
