This closes #924
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c78db9ad Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c78db9ad Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c78db9ad Branch: refs/heads/master Commit: c78db9addf0b08b1b4a3ca4ec5e3e7f3a0899a02 Parents: a96ea98 7e2820b Author: Maximilian Michels <m...@apache.org> Authored: Fri Sep 9 16:07:57 2016 +0200 Committer: Maximilian Michels <m...@apache.org> Committed: Fri Sep 9 16:07:57 2016 +0200 ---------------------------------------------------------------------- .../wrappers/streaming/io/BoundedSourceWrapper.java | 9 ++++++++- .../wrappers/streaming/io/UnboundedSourceWrapper.java | 8 +++++++- 2 files changed, 15 insertions(+), 2 deletions(-) ----------------------------------------------------------------------
