Github user gvramana commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1616#discussion_r155472604
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/CarbonLoaderUtil.java
---
@@ -132,10 +133,25 @@ public boolean accept(CarbonFile file) {
public static void deletePartialLoadDataIfExist(CarbonLoadModel
loadModel,
final boolean isCompactionFlow) throws IOException {
CarbonTable carbonTable =
loadModel.getCarbonDataLoadSchema().getCarbonTable();
- String metaDataLocation = carbonTable.getMetaDataFilepath();
- final LoadMetadataDetails[] details =
SegmentStatusManager.readLoadMetadata(metaDataLocation);
+ deletePartialLoad(loadModel, carbonTable, isCompactionFlow);
+ }
+
+ public static void deletePartialLoad(CarbonLoadModel loadModel,
CarbonTable carbonTable,
--- End diff --
Use same name, overloaded function deletePartialLoadDataIfExist
---
