HBASE-18754 (addendum) close the input resource
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2e648138 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2e648138 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2e648138 Branch: refs/heads/HBASE-18410 Commit: 2e6481386b80c2306e0e12a9c7cd137b63eaa006 Parents: dd70cc3 Author: Chia-Ping Tsai <chia7...@gmail.com> Authored: Wed Oct 25 12:31:37 2017 +0800 Committer: Chia-Ping Tsai <chia7...@gmail.com> Committed: Wed Oct 25 12:31:37 2017 +0800 ---------------------------------------------------------------------- .../org/apache/hadoop/hbase/regionserver/TimeRangeTracker.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/2e648138/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/TimeRangeTracker.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/TimeRangeTracker.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/TimeRangeTracker.java index 08d9853..203bea3 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/TimeRangeTracker.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/TimeRangeTracker.java @@ -199,8 +199,9 @@ public abstract class TimeRangeTracker { ProtobufUtil.mergeFrom(builder, data, pblen, data.length - pblen); return TimeRangeTracker.create(type, builder.getFrom(), builder.getTo()); } else { - DataInputStream in = new DataInputStream(new ByteArrayInputStream(data)); - return TimeRangeTracker.create(type, in.readLong(), in.readLong()); + try (DataInputStream in = new DataInputStream(new ByteArrayInputStream(data))) { + return TimeRangeTracker.create(type, in.readLong(), in.readLong()); + } } }
