Repository: tez Updated Branches: refs/heads/master 3baab5581 -> 5b75ef118
TEZ-3963. Possible InflaterInputStream leaked in TezCommonUtils and related classes (Jaume M via jlowe) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/5b75ef11 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/5b75ef11 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/5b75ef11 Branch: refs/heads/master Commit: 5b75ef118b5e7702485c29b91890c0639ac0e0b5 Parents: 3baab55 Author: Jason Lowe <[email protected]> Authored: Fri Jul 6 16:53:57 2018 -0500 Committer: Jason Lowe <[email protected]> Committed: Fri Jul 6 16:53:57 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/5b75ef11/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) {
