From fbcb4b23e2ffc6919d7396f7a0c20b796aea23f5 Mon Sep 17 00:00:00 2001 From: Zhihong Yu Date: Wed, 4 Dec 2013 14:28:53 +0000 Subject: [PATCH] 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 --- .../hadoop/hbase/mapreduce/TableOutputCommitter.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git 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 index 8039861bfd2..6c0c7a674dc 100644 --- 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 + { + } }