Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1608#discussion_r154835999
--- Diff:
core/src/main/java/org/apache/carbondata/core/statusmanager/SegmentStatusManager.java
---
@@ -493,6 +493,19 @@ public static void writeLoadDetailsIntoFile(String
dataLoadLocation,
invalidLoadIds.add(loadId);
return invalidLoadIds;
}
+ // if the segment status is in progress then no need to delete
that.
+ if (SegmentStatus.INSERT_IN_PROGRESS ==
loadMetadata.getSegmentStatus()) {
+ LOG.error("Cannot delete the Segment which is In Progress.
Segment is " + loadId);
+ invalidLoadIds.add(loadId);
+ return invalidLoadIds;
+ }
+ // if the segment status is overwrite in progress, then no need
to delete that.
+ if (SegmentStatus.INSERT_OVERWRITE_IN_PROGRESS ==
loadMetadata.getSegmentStatus()) {
+ LOG.error("Cannot delete the Segment which is Overwrite In
Progress. " +
--- End diff --
Please rephrase the sentence
`"Cannot delete the segemnt "+ loadId +" which is load overwrite in
progress" `
---
