[split] merged bq import stuff

twitter-archive · Feb 7, 2012 · ac1e222e0b7b8a33da4905d3973d0201329f421a · ac1e222
2 parents 742e01d + 2004763
commit ac1e222e0b7b8a33da4905d3973d0201329f421a
Unified Split

Showing with 2 additions and 1 deletion.

+2 −1 cassie-hadoop/src/main/scala/com/twitter/cassie/hadoop/CassieReducer.scala
diff --git a/cassie-hadoop/src/main/scala/com/twitter/cassie/hadoop/CassieReducer.scala b/cassie-hadoop/src/main/scala/com/twitter/cassie/hadoop/CassieReducer.scala
@@ -107,7 +107,8 @@ class CassieReducer extends Reducer[BytesWritable, ColumnWritable, BytesWritable
     case t: Throwable => {
       t.printStackTrace
       val toSleep = minBackoff * (1 << consecutiveFailures)
-      if (toSleep < maxBackoff) {
+      if(toSleep < maxBackoff) {
+        context.progress()
         Thread.sleep(toSleep)
         context.getCounter(CassieCounters.Counters.RETRY).increment(1)
         execute(context)