drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amansi...@apache.org
Subject [1/2] drill git commit: DRILL-5040: Parquet writer unable to delete table folder on abort
Date Sat, 11 Feb 2017 02:18:07 GMT
Repository: drill
Updated Branches:
  refs/heads/master 2b5f5428a -> c9a6ac4fc


DRILL-5040: Parquet writer unable to delete table folder on abort

close apache/drill#744


Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/f80d77e6
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/f80d77e6
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/f80d77e6

Branch: refs/heads/master
Commit: f80d77e6bb60afc562331192ac5d08545c1f1c02
Parents: 2b5f542
Author: Arina Ielchiieva <arina.yelchiyeva@gmail.com>
Authored: Mon Feb 6 13:11:02 2017 +0000
Committer: Aman Sinha <asinha@maprtech.com>
Committed: Fri Feb 10 09:06:08 2017 -0800

----------------------------------------------------------------------
 .../org/apache/drill/exec/store/parquet/ParquetRecordWriter.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/f80d77e6/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java
b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java
index a25699d..6850d36 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java
@@ -397,7 +397,7 @@ public class ParquetRecordWriter extends ParquetOutputRecordWriter {
     for (Path location : cleanUpLocations) {
       try {
         if (fs.exists(location)) {
-          fs.delete(location, false);
+          fs.delete(location, true);
           logger.info("Aborting writer. Location [{}] on file system [{}] is deleted.",
               location.toUri().getPath(), fs.getUri());
         }


Mime
View raw message