commit 3d8ce063986ad623d6ade4b55f1bbb1eb39f7641
author belugabehr <12578579+belugabehr@users.noreply.github.com> Sun Jan 05 13:24:15 2020 -0500
committer Fokko Driesprong <fokko@apache.org> Sun Jan 05 19:24:15 2020 +0100
tree 9834755f54ac0e0a314a955fec228f1a8b4a3a95
parent 1e15f604302ab96904eaa1c3d435d2a5b3632d3f

PARQUET-1727: Do Not Swallow InterruptedException in ParquetLoader (#715)

parquet-pig/src/main/java/org/apache/parquet/pig/ParquetLoader.java

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 @@
         return null;
       }
     } catch (InterruptedException e) {
-      Thread.interrupted();
+      Thread.currentThread().interrupt();
       throw new ParquetDecodingException("Interrupted", e);
     }
   }
@@ -331,7 +331,8 @@
         length += split.getLength();
       }
     } catch (InterruptedException e) {
-      LOG.warn("Interrupted: ", e);
+      LOG.warn("Interrupted", e);
+      Thread.currentThread().interrupt();
       return null;
     }
     ResourceStatistics stats = new ResourceStatistics();