You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ch...@apache.org on 2016/07/20 10:14:08 UTC
[40/50] [abbrv] incubator-carbondata git commit: [CARBONDATA-77]
removing the segment folder during the clean up. (#840)
[CARBONDATA-77] removing the segment folder during the clean up. (#840)
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/ad48c4c9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/ad48c4c9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/ad48c4c9
Branch: refs/heads/master
Commit: ad48c4c94c11a6f88afa12376178e6bad1a354ad
Parents: b81235d
Author: ravikiran23 <ra...@gmail.com>
Authored: Tue Jul 19 13:03:11 2016 +0530
Committer: Venkata Ramana G <g....@gmail.com>
Committed: Tue Jul 19 13:03:11 2016 +0530
----------------------------------------------------------------------
.../java/org/carbondata/spark/load/DeleteLoadFolders.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ad48c4c9/integration/spark/src/main/java/org/carbondata/spark/load/DeleteLoadFolders.java
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/java/org/carbondata/spark/load/DeleteLoadFolders.java b/integration/spark/src/main/java/org/carbondata/spark/load/DeleteLoadFolders.java
index 01d785a..6209753 100644
--- a/integration/spark/src/main/java/org/carbondata/spark/load/DeleteLoadFolders.java
+++ b/integration/spark/src/main/java/org/carbondata/spark/load/DeleteLoadFolders.java
@@ -202,6 +202,15 @@ public final class DeleteLoadFolders {
}
}
}
+ // need to delete the complete folder.
+ if(status){
+ if(!file.delete()){
+ LOGGER.warn("Unable to delete the folder as per delete command "
+ + file.getAbsolutePath());
+ status = false;
+ }
+ }
+
} else {
status = false;
}