You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ch...@apache.org on 2017/10/25 04:46:25 UTC
hbase git commit: HBASE-18754 (addendum) close the input resource
Repository: hbase
Updated Branches:
refs/heads/master dd70cc308 -> 2e6481386
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/master
Commit: 2e6481386b80c2306e0e12a9c7cd137b63eaa006
Parents: dd70cc3
Author: Chia-Ping Tsai <ch...@gmail.com>
Authored: Wed Oct 25 12:31:37 2017 +0800
Committer: Chia-Ping Tsai <ch...@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());
+ }
}
}