Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-24788 : TableOutputFormat source compatibility (ADDENDUM) 

Brought back InterruptedException in throws clause of getRecordWriter and checkOutputSpecs of TableOutputFormat
This commit is contained in:
Viraj Jasani 2020-08-08 14:17:04 +05:30
parent d492aea3f8
commit 3edfa1025c
No known key found for this signature in database
GPG Key ID: B3D6C0B41C8ADFD5
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java
View File

@ -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();