Index: src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java (revision 1096091) +++ src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java (working copy) @@ -104,13 +104,7 @@ @Override public void close(TaskAttemptContext context) throws IOException { - table.flushCommits(); - // The following call will shutdown all connections to the cluster from - // this JVM. It will close out our zk session otherwise zk wil log - // expired sessions rather than closed ones. If any other HTable instance - // running in this JVM, this next call will cause it damage. Presumption - // is that the above this.table is only instance. - HConnectionManager.deleteAllConnections(true); + table.close(); } /**