[parquet-mr] branch master updated: PARQUET-1727: Do Not Swallow InterruptedException in ParquetLoader (#715)

[fokko]

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

fokko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/parquet-mr.git


The following commit(s) were added to refs/heads/master by this push:
     new 3d8ce06  PARQUET-1727: Do Not Swallow InterruptedException in 
ParquetLoader (#715)
3d8ce06 is described below

commit 3d8ce063986ad623d6ade4b55f1bbb1eb39f7641
Author: belugabehr <12578579+belugab...@users.noreply.github.com>
AuthorDate: Sun Jan 5 13:24:15 2020 -0500

    PARQUET-1727: Do Not Swallow InterruptedException in ParquetLoader (#715)
---
 parquet-pig/src/main/java/org/apache/parquet/pig/ParquetLoader.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/parquet-pig/src/main/java/org/apache/parquet/pig/ParquetLoader.java 
b/parquet-pig/src/main/java/org/apache/parquet/pig/ParquetLoader.java
index 566dbee..e13bc64 100644
--- a/parquet-pig/src/main/java/org/apache/parquet/pig/ParquetLoader.java
+++ b/parquet-pig/src/main/java/org/apache/parquet/pig/ParquetLoader.java
@@ -256,7 +256,7 @@ public class ParquetLoader extends LoadFunc implements 
LoadMetadata, LoadPushDow
         return null;
       }
     } catch (InterruptedException e) {
-      Thread.interrupted();
+      Thread.currentThread().interrupt();
       throw new ParquetDecodingException("Interrupted", e);
     }
   }
@@ -331,7 +331,8 @@ public class ParquetLoader extends LoadFunc implements 
LoadMetadata, LoadPushDow
         length += split.getLength();
       }
     } catch (InterruptedException e) {
-      LOG.warn("Interrupted: ", e);
+      LOG.warn("Interrupted", e);
+      Thread.currentThread().interrupt();
       return null;
     }
     ResourceStatistics stats = new ResourceStatistics();