You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2016/04/10 02:17:54 UTC
hive git commit: HIVE-13405 : Fix Connection Leak in
OrcRawRecordMerger (Thomas Poepping via Prasanth J)
Repository: hive
Updated Branches:
refs/heads/master e98f7ac55 -> 3d7554447
HIVE-13405 : Fix Connection Leak in OrcRawRecordMerger (Thomas Poepping via Prasanth J)
Signed-off-by: Ashutosh Chauhan <ha...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/3d755444
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/3d755444
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/3d755444
Branch: refs/heads/master
Commit: 3d75544479db8a4defe0d5a53b31307c73bad550
Parents: e98f7ac
Author: Thomas Poepping <po...@amazon.com>
Authored: Mon Apr 4 13:47:00 2016 -0800
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Sat Apr 9 17:17:13 2016 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/3d755444/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
index f495be2..1fce282 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
@@ -546,13 +546,11 @@ public class OrcRawRecordMerger implements AcidInputFormat.RawReader<OrcStruct>{
Path deltaFile) throws IOException {
Path lengths = OrcRecordUpdater.getSideFile(deltaFile);
long result = Long.MAX_VALUE;
- try {
- FSDataInputStream stream = fs.open(lengths);
+ try (FSDataInputStream stream = fs.open(lengths)) {
result = -1;
while (stream.available() > 0) {
result = stream.readLong();
}
- stream.close();
return result;
} catch (IOException ioe) {
return result;