diff --git common/src/java/org/apache/hadoop/hive/common/FileUtils.java common/src/java/org/apache/hadoop/hive/common/FileUtils.java index 010c0ca..096c4ad 100644 --- common/src/java/org/apache/hadoop/hive/common/FileUtils.java +++ common/src/java/org/apache/hadoop/hive/common/FileUtils.java @@ -267,7 +267,12 @@ public final class FileUtils { TarArchiveEntry tarEntry = new TarArchiveEntry(f, f.getName()); tOut.setLongFileMode(TarArchiveOutputStream.LONGFILE_GNU); tOut.putArchiveEntry(tarEntry); - IOUtils.copy(new FileInputStream(f), tOut); // copy with 8K buffer, not close + FileInputStream input = new FileInputStream(f); + try { + IOUtils.copy(input, tOut); // copy with 8K buffer, not close + } finally { + input.close(); + } tOut.closeArchiveEntry(); } tOut.close(); // finishes inside