Repository: incubator-beam Updated Branches: refs/heads/master 6814a99c2 -> b25131422
WordCountIT: uses input with fewer keys. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/95ca1add Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/95ca1add Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/95ca1add Branch: refs/heads/master Commit: 95ca1add2df97a5bc6fa96c0810b8d6a0cb0c00c Parents: 6814a99 Author: Pei He <pe...@google.com> Authored: Fri Nov 11 14:13:02 2016 -0800 Committer: Davor Bonaci <da...@google.com> Committed: Fri Nov 11 16:02:55 2016 -0800 ---------------------------------------------------------------------- .../java/org/apache/beam/examples/WindowedWordCountIT.java | 6 ++++-- .../src/test/java/org/apache/beam/examples/WordCountIT.java | 5 ++++- 2 files changed, 8 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/95ca1add/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java ---------------------------------------------------------------------- diff --git a/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java b/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java index a5113c8..5d77dd5 100644 --- a/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java +++ b/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java @@ -38,7 +38,9 @@ import org.junit.runners.JUnit4; @RunWith(JUnit4.class) public class WindowedWordCountIT { - private static final String DEFAULT_OUTPUT_CHECKSUM = "ff54f6f42b2afeb146206c1e8e915deaee0362b4"; + private static final String DEFAULT_INPUT = + "gs://apache-beam-samples/shakespeare/winterstale-personae"; + private static final String DEFAULT_OUTPUT_CHECKSUM = "cd5b52939257e12428a9fa085c32a84dd209b180"; /** * Options for the {@link WindowedWordCount} Integration Test. @@ -67,7 +69,7 @@ public class WindowedWordCountIT { WindowedWordCountITOptions options = TestPipeline.testingPipelineOptions().as(WindowedWordCountITOptions.class); options.setStreaming(isStreaming); - options.setTestTimeoutSeconds(1200L); + options.setInputFile(DEFAULT_INPUT); // Note: currently unused because the example writes to BigQuery, but WindowedWordCount.Options // are tightly coupled to WordCount.Options, where the option is required. http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/95ca1add/examples/java/src/test/java/org/apache/beam/examples/WordCountIT.java ---------------------------------------------------------------------- diff --git a/examples/java/src/test/java/org/apache/beam/examples/WordCountIT.java b/examples/java/src/test/java/org/apache/beam/examples/WordCountIT.java index 487f04b..f2afe6a 100644 --- a/examples/java/src/test/java/org/apache/beam/examples/WordCountIT.java +++ b/examples/java/src/test/java/org/apache/beam/examples/WordCountIT.java @@ -36,7 +36,9 @@ import org.junit.runners.JUnit4; @RunWith(JUnit4.class) public class WordCountIT { - private static final String DEFAULT_OUTPUT_CHECKSUM = "8ae94f799f97cfd1cb5e8125951b32dfb52e1f12"; + private static final String DEFAULT_INPUT = + "gs://apache-beam-samples/shakespeare/winterstale-personae"; + private static final String DEFAULT_OUTPUT_CHECKSUM = "508517575eba8d8d5a54f7f0080a00951cfe84ca"; /** * Options for the WordCount Integration Test. @@ -56,6 +58,7 @@ public class WordCountIT { public void testE2EWordCount() throws Exception { WordCountITOptions options = TestPipeline.testingPipelineOptions().as(WordCountITOptions.class); + options.setInputFile(DEFAULT_INPUT); options.setOutput(IOChannelUtils.resolve( options.getTempRoot(), String.format("WordCountIT-%tF-%<tH-%<tM-%<tS-%<tL", new Date()),