[FLINK-6105] Properly handle InterruptedException in HadoopInputFormatBase

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: zhangminglei
• Reporter: Ted Yu
• Created: 17/Mar/17 15:36
• Updated: 18/Oct/19 11:24
• Resolved: 18/Oct/19 11:17

Description

When catching InterruptedException, we should throw InterruptedIOException instead of IOException.

The following example is from HadoopInputFormatBase :

    try {
      splits = this.mapreduceInputFormat.getSplits(jobContext);
    } catch (InterruptedException e) {
      throw new IOException("Could not get Splits.", e);
    }

There may be other places where IOE is thrown.

Issue Links

• links to: GitHub Pull Request #4316
• links to: GitHub Pull Request #4316