Luke's comments
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4e18be8e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4e18be8e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4e18be8e Branch: refs/heads/master Commit: 4e18be8ecbc9580e601167f994a04aacfb171532 Parents: a8f9e99 Author: Mark Shields <[email protected]> Authored: Mon Apr 25 15:50:37 2016 -0700 Committer: Mark Shields <[email protected]> Committed: Mon Apr 25 15:50:37 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/runners/dataflow/TestCountingSourceTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4e18be8e/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSourceTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSourceTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSourceTest.java index b122bc0..9377905 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSourceTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/dataflow/TestCountingSourceTest.java @@ -40,7 +40,8 @@ public class TestCountingSourceTest { public void testRespectsCheckpointContract() throws IOException { TestCountingSource source = new TestCountingSource(3); PipelineOptions options = PipelineOptionsFactory.create(); - TestCountingSource.CountingSourceReader reader = source.createReader(options, null); + TestCountingSource.CountingSourceReader reader = + source.createReader(options, null /* no checkpoint */); assertTrue(reader.start()); assertEquals(0L, (long) reader.getCurrent().getValue()); assertTrue(reader.advance());
