{"record":{"id":"52de06b3da964fcd","repo":"apache/hadoop","slug":"interrupt-exception","errorCode":null,"errorMessage":"interrupt exception","messagePattern":"interrupt exception","errorType":"exception","errorClass":"IOException","httpStatus":null,"severity":"error","filePath":"hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTask.java","lineNumber":627,"sourceCode":"          @Override\n          public void configure(JobConf job) { }\n          @Override\n          public int getPartition(K key, V value, int numPartitions) {\n            return numPartitions - 1;\n          }\n        };\n      }\n      this.collector = collector;\n    }\n\n    @Override\n    public void collect(K key, V value) throws IOException {\n      try {\n        collector.collect(key, value,\n                          partitioner.getPartition(key, value, numPartitions));\n      } catch (InterruptedException ie) {\n        Thread.currentThread().interrupt();\n        throw new IOException(\"interrupt exception\", ie);\n      }\n    }\n  }\n\n  private class NewDirectOutputCollector<K,V>\n  extends org.apache.hadoop.mapreduce.RecordWriter<K,V> {\n    private final org.apache.hadoop.mapreduce.RecordWriter out;\n\n    private final TaskReporter reporter;\n\n    private final Counters.Counter mapOutputRecordCounter;\n    private final Counters.Counter fileOutputByteCounter; \n    private final List<Statistics> fsStats;\n    \n    @SuppressWarnings(\"unchecked\")\n    NewDirectOutputCollector(MRJobConfig jobContext,\n        JobConf job, TaskUmbilicalProtocol umbilical, TaskReporter reporter) \n    throws IOException, ClassNotFoundException, InterruptedException {","sourceCodeStart":609,"sourceCodeEnd":645,"githubUrl":"https://github.com/apache/hadoop/blob/2add9630210752f88ceb1bb74eb65e37bf41da8e/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTask.java#L609-L645","documentation":"Error \"interrupt exception\" thrown in apache/hadoop.","triggerScenarios":"Thrown at hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/MapTask.java:627 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["The map task thread was interrupted, usually during kill/shutdown; rerun the task if the interrupt was unexpected."],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"2add9630210752f88ceb1bb74eb65e37bf41da8e","analyzedAt":"2026-08-22T19:55:07.957Z","schemaVersion":2},"datasetVersion":"2026-08-22T20:17:22.307Z"}