diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java index 52f340251c2d..8da8d83d9231 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java @@ -155,10 +155,11 @@ public void write(KEY key, Mutation value) * @param context The current task context. * @return The newly created writer instance. * @throws IOException When creating the writer fails. + * @throws InterruptedException When the job is cancelled. */ @Override public RecordWriter getRecordWriter(TaskAttemptContext context) - throws IOException { + throws IOException, InterruptedException { return new TableRecordWriter(); } @@ -167,11 +168,11 @@ public RecordWriter getRecordWriter(TaskAttemptContext context) * * @param context The current context. * @throws IOException When the check fails. + * @throws InterruptedException When the job is aborted. * @see OutputFormat#checkOutputSpecs(JobContext) */ @Override - public void checkOutputSpecs(JobContext context) - throws IOException { + public void checkOutputSpecs(JobContext context) throws IOException, InterruptedException { Configuration hConf = getConf(); if (hConf == null) { hConf = context.getConfiguration();