[hive] branch master updated (5854347 -> 639b41a)
This is an automated email from the ASF dual-hosted git repository. vihangk1 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/hive.git. from 5854347 HIVE-25019: Rename metrics that have spaces in the name (Antal Sinkovits, reviewed by Karen Coppage) add 639b41a HIVE-25005: Provide default implementation for HMS APIs (Kishen Das, reviewed by Naveen Gangam and Vihang Karajgaonkar) No new revisions were added by this update. Summary of changes: .../metastore/AbstractThriftHiveMetastore.java | 1610 1 file changed, 1610 insertions(+) create mode 100644 standalone-metastore/metastore-common/src/main/java/org/apache/hadoop/hive/metastore/AbstractThriftHiveMetastore.java
[hive] branch branch-3.1 updated: HIVE-24851: Fix reader leak in AvroGenericRecordReader ( Lukasz Osipiuk reviewed by Peter Vary)
This is an automated email from the ASF dual-hosted git repository.
pvary pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new a93798f HIVE-24851: Fix reader leak in AvroGenericRecordReader (
Lukasz Osipiuk reviewed by Peter Vary)
a93798f is described below
commit a93798f40a81506f2b0fdee224465d432161a0e0
Author: Łukasz Osipiuk
AuthorDate: Mon Apr 19 09:56:25 2021 +0100
HIVE-24851: Fix reader leak in AvroGenericRecordReader ( Lukasz Osipiuk
reviewed by Peter Vary)
Closes (#2040)
---
.../hive/ql/io/avro/AvroGenericRecordReader.java | 36 --
1 file changed, 26 insertions(+), 10 deletions(-)
diff --git
a/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java
b/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java
index 485337e..8944eac 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java
@@ -87,20 +87,36 @@ public class AvroGenericRecordReader implements
}
if (split.getLength() == 0) {
- this.isEmptyInput = true;
- this.start = 0;
this.reader = null;
-}
-else {
- this.isEmptyInput = false;
+ this.isEmptyInput = true;
+} else {
this.reader = new DataFileReader(new
FsInput(split.getPath(), job), gdr);
- this.reader.sync(split.getStart());
- this.start = reader.tell();
+ this.isEmptyInput = false;
}
-this.stop = split.getStart() + split.getLength();
-this.recordReaderID = new UID();
-this.writerTimezone = extractWriterTimezoneFromMetadata(job, split, gdr);
+try {
+ if (this.isEmptyInput) {
+this.start = 0;
+ } else {
+this.reader.sync(split.getStart());
+this.start = reader.tell();
+ }
+ this.stop = split.getStart() + split.getLength();
+ this.recordReaderID = new UID();
+
+ this.writerTimezone = extractWriterTimezoneFromMetadata(job, split, gdr);
+} catch (Exception e) {
+ if (this.reader != null) {
+try {
+ this.reader.close();
+} catch (Exception closeException) {
+ if (closeException != e) {
+e.addSuppressed(closeException);
+ }
+}
+ }
+ throw e;
+}
}
/**
[hive] branch master updated (5580209 -> 5854347)
This is an automated email from the ASF dual-hosted git repository. klcopp pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/hive.git. from 5580209 HIVE-25017: Fix response in GetLatestCommittedCompaction (Yu-Wen Lai, reviewed by Karen Coppage) add 5854347 HIVE-25019: Rename metrics that have spaces in the name (Antal Sinkovits, reviewed by Karen Coppage) No new revisions were added by this update. Summary of changes: .../hadoop/hive/ql/txn/compactor/TestCompactionMetrics.java| 8 ++-- .../hadoop/hive/metastore/metrics/AcidMetricService.java | 10 +- 2 files changed, 15 insertions(+), 3 deletions(-)
[hive] branch master updated (0182ef3 -> 5580209)
This is an automated email from the ASF dual-hosted git repository. klcopp pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/hive.git. from 0182ef3 HIVE-25009: Compaction worker and initiator version check can cause NPE if the COMPACTION_QUEUE is empty (Antal Sinkovits, reviewed by Denys Kuzmenko) add 5580209 HIVE-25017: Fix response in GetLatestCommittedCompaction (Yu-Wen Lai, reviewed by Karen Coppage) No new revisions were added by this update. Summary of changes: .../org/apache/hadoop/hive/metastore/txn/TestCompactionTxnHandler.java | 2 ++ .../src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java | 2 ++ 2 files changed, 4 insertions(+)
[hive] branch master updated (6d8c9aa -> 0182ef3)
This is an automated email from the ASF dual-hosted git repository. dkuzmenko pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/hive.git. from 6d8c9aa HIVE-24928: In case of iceberg tables use basic statistics provided by the HiveStorageHandler (#2111) (Laszlo Pinter, reviewed by Zoltan Haindrich, Peter Vary and Marton Bod) add 0182ef3 HIVE-25009: Compaction worker and initiator version check can cause NPE if the COMPACTION_QUEUE is empty (Antal Sinkovits, reviewed by Denys Kuzmenko) No new revisions were added by this update. Summary of changes: ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-)
