This closes #2406
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9b8f2309 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9b8f2309 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9b8f2309 Branch: refs/heads/jstorm-runner Commit: 9b8f23095665cc7d7872969290a01847de8071b6 Parents: f7d727c c62d698 Author: Jean-Baptiste Onofré <[email protected]> Authored: Mon Apr 17 11:03:51 2017 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Mon Apr 17 11:03:51 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/UnboundedSource.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) ----------------------------------------------------------------------
