This closes #630
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1a7cd411 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1a7cd411 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1a7cd411 Branch: refs/heads/master Commit: 1a7cd4112aab68d05dc59700883f63a082ea38e0 Parents: ee1a3bc 9000d95 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Wed Jul 13 14:16:02 2016 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Wed Jul 13 14:16:02 2016 +0200 ---------------------------------------------------------------------- .../FlinkStreamingTransformTranslators.java | 10 ++++++--- .../streaming/io/UnboundedFlinkSource.java | 23 ++++++++++++++++++++ 2 files changed, 30 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
