Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2752#discussion_r219893862
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/store/writer/AbstractFactDataWriter.java
---
@@ -418,6 +423,24 @@ protected void closeExecutorService() throws
CarbonDataWriterException {
CarbonDataWriterException exception = null;
try {
listener.finish();
+ String tableName = this.model.getTableName();
+ // Delete CarbonData and CarbonIndex files after copying from temp
location
+ if (null != carbonDataFileTempPath && null ==
model.getTableSpec().getCarbonTable()
+ .getBucketingInfo(tableName)) {
+ String deleteDataAndIndexInTempPath =
--- End diff --
Why not delete this path recursively so that we do not need the traverse
and delete them one by one?
You can find the delete* methods in `CarbonUtil`
---
