(hive) branch master updated: HIVE-28133: Log the original exception in HiveIOExceptionHandlerUtil#handleRecordReaderException (Denys Kuzmenko, reviewed by Laszlo Bodor)

[dkuzmenko]

This is an automated email from the ASF dual-hosted git repository.

dkuzmenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new a3e5298cb01 HIVE-28133: Log the original exception in 
HiveIOExceptionHandlerUtil#handleRecordReaderException (Denys Kuzmenko, 
reviewed by Laszlo Bodor)
a3e5298cb01 is described below

commit a3e5298cb01a9439227e6ea65a818f363ccbdef2
Author: Denys Kuzmenko <denisk...@gmail.com>
AuthorDate: Mon Apr 15 11:10:17 2024 +0300

    HIVE-28133: Log the original exception in 
HiveIOExceptionHandlerUtil#handleRecordReaderException (Denys Kuzmenko, 
reviewed by Laszlo Bodor)
    
    Closes #5139
---
 .../java/org/apache/hadoop/hive/io/HiveIOExceptionHandlerUtil.java  | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/shims/common/src/main/java/org/apache/hadoop/hive/io/HiveIOExceptionHandlerUtil.java
 
b/shims/common/src/main/java/org/apache/hadoop/hive/io/HiveIOExceptionHandlerUtil.java
index 4a774004e43..c9338ef3f21 100644
--- 
a/shims/common/src/main/java/org/apache/hadoop/hive/io/HiveIOExceptionHandlerUtil.java
+++ 
b/shims/common/src/main/java/org/apache/hadoop/hive/io/HiveIOExceptionHandlerUtil.java
@@ -21,9 +21,13 @@ import java.io.IOException;
 
 import org.apache.hadoop.mapred.JobConf;
 import org.apache.hadoop.mapred.RecordReader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class HiveIOExceptionHandlerUtil {
 
+  private static final Logger LOG = 
LoggerFactory.getLogger(HiveIOExceptionHandlerUtil.class.getName());
+
   private static final ThreadLocal<HiveIOExceptionHandlerChain> 
handlerChainInstance =
     new ThreadLocal<HiveIOExceptionHandlerChain>();
 
@@ -52,6 +56,7 @@ public class HiveIOExceptionHandlerUtil {
    */
   public static RecordReader handleRecordReaderCreationException(Exception e,
       JobConf job) throws IOException {
+    LOG.error("RecordReader#init() threw an exception: ", e);
     HiveIOExceptionHandlerChain ioExpectionHandlerChain = get(job);
     if (ioExpectionHandlerChain != null) {
       return ioExpectionHandlerChain.handleRecordReaderCreationException(e);
@@ -72,6 +77,7 @@ public class HiveIOExceptionHandlerUtil {
    */
   public static boolean handleRecordReaderNextException(Exception e, JobConf 
job)
       throws IOException {
+    LOG.error("RecordReader#next() threw an exception: ", e);
     HiveIOExceptionHandlerChain ioExpectionHandlerChain = get(job);
     if (ioExpectionHandlerChain != null) {
       return ioExpectionHandlerChain.handleRecordReaderNextException(e);