diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
index c765c99fd01..7feb7a96c12 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
@@ -119,9 +119,9 @@ public class MultiTableOutputFormat extends OutputFormat<ImmutableBytesWritable,
     @Override
     public void close(TaskAttemptContext context) throws IOException {
       for (BufferedMutator mutator : mutatorMap.values()) {
-        mutator.flush();
+        mutator.close();
       }
-      if(connection != null){
+      if (connection != null) {
         connection.close();
       }
     }