Closes #1168
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/44b9f4eb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/44b9f4eb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/44b9f4eb Branch: refs/heads/gearpump-runner Commit: 44b9f4ebbc3229d8a9ec46b0c377e57ad0176dbe Parents: dfaf2a8 7e9ad99 Author: Dan Halperin <dhalp...@google.com> Authored: Mon Oct 24 13:16:51 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon Oct 24 13:16:51 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/OffsetBasedSource.java | 4 +-- .../beam/sdk/io/OffsetBasedSourceTest.java | 30 +++++++++++++++----- 2 files changed, 25 insertions(+), 9 deletions(-) ----------------------------------------------------------------------