Github user Indhumathi27 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2752#discussion_r220142943
--- 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 --
Changed the code fix. Delete carbon index and carbon data files in temp
location, once it is copied from temp to target path
---
