diff options
author | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2017-02-06 13:11:02 +0000 |
---|---|---|
committer | Aman Sinha <asinha@maprtech.com> | 2017-02-10 09:06:08 -0800 |
commit | f80d77e6bb60afc562331192ac5d08545c1f1c02 (patch) | |
tree | 3f01c0ea8e7496d1405af78727e30b6fc966d077 | |
parent | 2b5f5428af6951c71461c2bd2253e184ad0c4631 (diff) |
DRILL-5040: Parquet writer unable to delete table folder on abort
close apache/drill#744
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetRecordWriter.java | 2 |
1 files changed, 1 insertions, 1 deletions
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 a25699da5..6850d3661 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()); } |