aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArina Ielchiieva <arina.yelchiyeva@gmail.com>2017-02-06 13:11:02 +0000
committerAman Sinha <asinha@maprtech.com>2017-02-10 09:06:08 -0800
commitf80d77e6bb60afc562331192ac5d08545c1f1c02 (patch)
tree3f01c0ea8e7496d1405af78727e30b6fc966d077
parent2b5f5428af6951c71461c2bd2253e184ad0c4631 (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.java2
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());
}