diff --git a/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/protocolPB/OMPBHelper.java b/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/protocolPB/OMPBHelper.java index ccb2080a8758..e28c9477f299 100644 --- a/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/protocolPB/OMPBHelper.java +++ b/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/protocolPB/OMPBHelper.java @@ -242,11 +242,13 @@ public static MD5MD5Crc32FileChecksumProto convert( DataOutputBuffer buf = new DataOutputBuffer(); checksum.write(buf); byte[] bytes = buf.getData(); - DataInputBuffer buffer = new DataInputBuffer(); - buffer.reset(bytes, 0, bytes.length); - int bytesPerCRC = buffer.readInt(); - long crcPerBlock = buffer.readLong(); - buffer.close(); + int bytesPerCRC; + long crcPerBlock; + try (DataInputBuffer buffer = new DataInputBuffer()) { + buffer.reset(bytes, 0, bytes.length); + bytesPerCRC = buffer.readInt(); + crcPerBlock = buffer.readLong(); + } int offset = Integer.BYTES + Long.BYTES; ByteString byteString = ByteString.copyFrom(