Skip to content
This repository has been archived by the owner on Feb 8, 2019. It is now read-only.

Commit

Permalink
minor fix for regression tests
Browse files Browse the repository at this point in the history
- wait for results file to be available
  • Loading branch information
matthieumorel committed Jan 31, 2012
1 parent bac25cb commit dd96e87
Showing 1 changed file with 6 additions and 0 deletions.
Expand Up @@ -151,6 +151,12 @@ public void doTestCheckpointingAndRecovery(String backendConf)
signalTextProcessed.await(10, TimeUnit.SECONDS);
File results = new File(S4TestCase.DEFAULT_TEST_OUTPUT_DIR
+ File.separator + "wordcount");
if (!results.exists()) {
// in case the results file isn't ready yet
Thread.sleep(1000);
results = new File(S4TestCase.DEFAULT_TEST_OUTPUT_DIR
+ File.separator + "wordcount");
}
String s = TestUtils.readFile(results);
Assert.assertEquals("be=2;da=2;doobie=5;not=1;or=1;to=2;", s);

Expand Down

0 comments on commit dd96e87

Please sign in to comment.