Merge 16c3d5d into 0e85887

apache · Oct 18, 2018 · a9caee3 · a9caee3
2 parents 0e85887 + 16c3d5d
commit a9caee3
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonTableOutputFormat.java b/hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonTableOutputFormat.java
@@ -267,9 +267,6 @@ public RecordWriter<NullWritable, ObjectArrayWritable> getRecordWriter(
             iterator.closeWriter(true);
           }
           dataLoadExecutor.close();
-          // clean up the folders and files created locally for data load operation
-          TableProcessingOperations.deleteLocalDataLoadFolderLocation(loadModel, false, false);
-
           throw new RuntimeException(e);
         } finally {
           ThreadLocalSessionInfo.unsetAll();

diff --git a/...ing/src/main/java/org/apache/carbondata/processing/loading/TableProcessingOperations.java b/...ing/src/main/java/org/apache/carbondata/processing/loading/TableProcessingOperations.java
@@ -146,6 +146,7 @@ public static void deleteLocalDataLoadFolderLocation(String tempLocationKey, Str
         }
       });
     } finally {
+      CarbonProperties.getInstance().removeProperty(tempLocationKey);
       if (null != localFolderDeletionService) {
         localFolderDeletionService.shutdown();
       }