HBASE-9485 TableOutputCommitter should implement recovery if we don't want jobs to start from 0 on RM restart

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1547803 13f79535-47bb-0310-9956-ffa450edef68
2013-12-04 14:28:53 +00:00 · 2013-12-04 14:28:53 +00:00 · fbcb4b23e2
parent f8139d1bf5
commit fbcb4b23e2
1 changed files with 8 additions and 0 deletions
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputCommitter.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputCommitter.java
@ -58,4 +58,12 @@ public class TableOutputCommitter extends OutputCommitter {
  public void setupTask(TaskAttemptContext arg0) throws IOException {
  }

+  public boolean isRecoverySupported() {
+    return true;
+  }
+
+  public void recoverTask(TaskAttemptContext taskContext)
+  throws IOException
+  {
+  }
 }