This closes #2262
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6fa1fca4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6fa1fca4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6fa1fca4 Branch: refs/heads/master Commit: 6fa1fca4f23a36be6e43fd31f93f28990475d805 Parents: 6816d98 00f55f8 Author: Thomas Groh <[email protected]> Authored: Mon Mar 20 09:26:06 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Mon Mar 20 09:26:06 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/core/UnboundedReadFromBoundedSource.java | 10 ++++++++-- .../main/java/org/apache/beam/sdk/transforms/Create.java | 4 ++-- 2 files changed, 10 insertions(+), 4 deletions(-) ----------------------------------------------------------------------
