You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by vj...@apache.org on 2020/08/08 09:02:52 UTC
[hbase] branch branch-2.2 updated: HBASE-24788 : TableOutputFormat
source compatibility (ADDENDUM)
This is an automated email from the ASF dual-hosted git repository.
vjasani pushed a commit to branch branch-2.2
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.2 by this push:
new cb21c5a HBASE-24788 : TableOutputFormat source compatibility (ADDENDUM)
cb21c5a is described below
commit cb21c5a5ed29de5dcd978c22ab0aa54038e4de95
Author: Viraj Jasani <vj...@apache.org>
AuthorDate: Sat Aug 8 14:17:04 2020 +0530
HBASE-24788 : TableOutputFormat source compatibility (ADDENDUM)
Brought back InterruptedException in throws clause of getRecordWriter and checkOutputSpecs of TableOutputFormat
---
.../java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
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 52f3402..8da8d83 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 @@ implements Configurable {
* @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<KEY, Mutation> getRecordWriter(TaskAttemptContext context)
- throws IOException {
+ throws IOException, InterruptedException {
return new TableRecordWriter();
}
@@ -167,11 +168,11 @@ implements Configurable {
*
* @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();