[TEZ-3962] Configuration decode leaks an Inflater object

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.2, 0.10.0
• Fix Version/s: 0.9.2, 0.10.0
• Hadoop Flags: Reviewed
• Assignee: Eric Wohlstadter
• Reporter: Gopal Vijayaraghavan
• Created: 26/Jun/18 22:40
• Updated: 19/Apr/19 19:21
• Resolved: 28/Jun/18 21:19

Description

public static Configuration createConfFromByteString(ByteString byteString) throws IOException {
...
    InflaterInputStream uncompressIs = new InflaterInputStream(byteString.newInput());
    DAGProtos.ConfigurationProto confProto = DAGProtos.ConfigurationProto.parseFrom(uncompressIs);

InflaterInputStream is never closed, this will get eventually collected - but the off-heap buffers for Inflater leaks temporarily.