Index: hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/TaskCommitContextRegistry.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/TaskCommitContextRegistry.java (revision 9f47b11fbb572644c74e6162203b892623d5a99e) +++ hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/TaskCommitContextRegistry.java (revision ) @@ -71,7 +71,8 @@ public synchronized void commitTask(TaskAttemptContext context) throws IOException { String key = generateKey(context); if (!taskCommitters.containsKey(key)) { - throw new IOException("No callback registered for TaskAttemptID:" + key); + LOG.warn("No callback registered for TaskAttemptID:" + key + ". Skipping."); + return; } try { @@ -99,7 +100,8 @@ public synchronized void abortTask(TaskAttemptContext context) throws IOException { String key = generateKey(context); if (!taskCommitters.containsKey(key)) { - throw new IOException("No callback registered for TaskAttemptID:" + key); + LOG.warn("No callback registered for TaskAttemptID:" + key + ". Skipping."); + return; } try {