Repository: tez Updated Branches: refs/heads/branch-0.9 c04416d86 -> 8c60086f3
TEZ-3963. Possible InflaterInputStream leaked in TezCommonUtils and related classes (Jaume M via jlowe) (cherry picked from commit 5b75ef118b5e7702485c29b91890c0639ac0e0b5) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/8c60086f Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/8c60086f Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/8c60086f Branch: refs/heads/branch-0.9 Commit: 8c60086f31ba954171d38b30385cee762b0eb4af Parents: c04416d Author: Jason Lowe <[email protected]> Authored: Fri Jul 6 16:53:57 2018 -0500 Committer: Jason Lowe <[email protected]> Committed: Fri Jul 6 16:55:28 2018 -0500 ---------------------------------------------------------------------- tez-api/src/main/java/org/apache/tez/common/TezCommonUtils.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/8c60086f/tez-api/src/main/java/org/apache/tez/common/TezCommonUtils.java ---------------------------------------------------------------------- diff --git a/tez-api/src/main/java/org/apache/tez/common/TezCommonUtils.java b/tez-api/src/main/java/org/apache/tez/common/TezCommonUtils.java index 9cb76d9..c8e8e02 100644 --- a/tez-api/src/main/java/org/apache/tez/common/TezCommonUtils.java +++ b/tez-api/src/main/java/org/apache/tez/common/TezCommonUtils.java @@ -394,8 +394,9 @@ public class TezCommonUtils { @Private public static byte[] decompressByteStringToByteArray(ByteString byteString, Inflater inflater) throws IOException { inflater.reset(); - return IOUtils.toByteArray(new InflaterInputStream(byteString.newInput(), inflater)); - + try (InflaterInputStream inflaterInputStream = new InflaterInputStream(byteString.newInput(), inflater)) { + return IOUtils.toByteArray(inflaterInputStream); + } } public static String getCredentialsInfo(Credentials credentials, String identifier) {
