Index: src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java =================================================================== --- src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java (revision 1342480) +++ src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java (working copy) @@ -200,7 +200,6 @@ } } finally { if( client != null ) { - client.close(); } // HCatUtil.logAllTokens(LOG,job); } Index: src/java/org/apache/hcatalog/mapreduce/InitializeInput.java =================================================================== --- src/java/org/apache/hcatalog/mapreduce/InitializeInput.java (revision 1342480) +++ src/java/org/apache/hcatalog/mapreduce/InitializeInput.java (working copy) @@ -128,7 +128,6 @@ return HCatUtil.serialize(inputJobInfo); } finally { if (client != null ) { - client.close(); } } Index: src/java/org/apache/hcatalog/mapreduce/FileOutputCommitterContainer.java =================================================================== --- src/java/org/apache/hcatalog/mapreduce/FileOutputCommitterContainer.java (revision 1342480) +++ src/java/org/apache/hcatalog/mapreduce/FileOutputCommitterContainer.java (working copy) @@ -427,7 +427,6 @@ } } finally { if( client != null ) { - client.close(); } } }