This closes #3693: [BEAM-2734] Unbreaks some Dataflow ValidatesRunner tests
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aadbe36f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aadbe36f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aadbe36f Branch: refs/heads/master Commit: aadbe36ff66b69e7eb55fb4977cb59b93b3269e2 Parents: df36bd9 97b12d5 Author: Eugene Kirpichov <[email protected]> Authored: Fri Aug 4 20:37:14 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Fri Aug 4 20:37:14 2017 -0700 ---------------------------------------------------------------------- .../construction/UnboundedReadFromBoundedSource.java | 11 ++++++++--- .../src/main/java/org/apache/beam/sdk/io/Source.java | 14 +++++++++++++- 2 files changed, 21 insertions(+), 4 deletions(-) ----------------------------------------------------------------------
