You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/04/26 01:16:31 UTC
[5/6] incubator-beam git commit: Luke's comments
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 <ma...@google.com>
Authored: Mon Apr 25 15:50:37 2016 -0700
Committer: Mark Shields <ma...@google.com>
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());