diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/RecordReader.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/RecordReader.java index 6e2c89fd8c..0a996dcc03 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/RecordReader.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/RecordReader.java @@ -18,6 +18,7 @@ package org.apache.hadoop.mapred; +import java.io.Closeable; import java.io.IOException; import org.apache.hadoop.classification.InterfaceAudience; @@ -38,7 +39,7 @@ */ @InterfaceAudience.Public @InterfaceStability.Stable -public interface RecordReader { +public interface RecordReader extends Closeable{ /** * Reads the next key/value pair from the input for processing. * @@ -74,7 +75,8 @@ public interface RecordReader { * Close this {@link InputSplit} to future operations. * * @throws IOException - */ + */ + @Override public void close() throws IOException; /**