add compatibility with Hadoop 0.20.x

partially address elastic#44
williamrandolph · May 13, 2013 · 439214f · 439214f
1 parent e3ef2ac
commit 439214f
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/main/java/org/elasticsearch/hadoop/mr/ESOutputFormat.java b/src/main/java/org/elasticsearch/hadoop/mr/ESOutputFormat.java
@@ -94,6 +94,13 @@ public void commitTask(org.apache.hadoop.mapred.TaskAttemptContext taskContext)
         public void abortTask(org.apache.hadoop.mapred.TaskAttemptContext taskContext) throws IOException {
             //no-op
         }
+
+        @Override
+        @Deprecated
+        public void cleanupJob(org.apache.hadoop.mapred.JobContext context) throws IOException {
+            // no-op
+            // added for compatibility with hadoop 0.20.x (used by old tools, such as Cascalog)
+        }
     }
 
     protected static class ESRecordWriter extends RecordWriter<Object, Object> implements org.apache.hadoop.mapred.RecordWriter<Object, Object> {