svn commit: r961540 - /mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java

[drew]

Author: drew
Date: Thu Jul  8 00:04:49 2010
New Revision: 961540

URL: http://svn.apache.org/viewvc?rev=961540&view=rev
Log:
MAHOUT-167 MAHOUT-417: left out job.waitForCompletion(true) in 
generateCollocations method

Modified:
    
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java

Modified: 
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java
URL: 
http://svn.apache.org/viewvc/mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java?rev=961540&r1=961539&r2=961540&view=diff
==============================================================================
--- 
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java
 (original)
+++ 
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java
 Thu Jul  8 00:04:49 2010
@@ -200,7 +200,7 @@ public final class CollocDriver extends 
                                           boolean emitUnigrams,
                                           int maxNGramSize,
                                           int reduceTasks,
-                                          int minSupport) throws IOException {
+                                          int minSupport) throws IOException, 
ClassNotFoundException, InterruptedException {
 
     Configuration con = new Configuration(baseConf);
     con.setBoolean(EMIT_UNIGRAMS, emitUnigrams);
@@ -230,6 +230,8 @@ public final class CollocDriver extends 
     job.setOutputFormatClass(SequenceFileOutputFormat.class);
     job.setReducerClass(CollocReducer.class);
     job.setNumReduceTasks(reduceTasks);
+    
+    job.waitForCompletion(true);
 
     return 
job.getCounters().findCounter(CollocMapper.Count.NGRAM_TOTAL).getValue();
   }