Github user zzcclp commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2050#discussion_r174373603
--- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateTableHelper.scala ---
@@ -166,8 +166,9 @@ case class PreAggregateTableHelper(
// table.
SegmentStatusManager.deleteLoadsAndUpdateMetadata(parentTable, false)
val loadAvailable = SegmentStatusManager.readLoadMetadata(parentTable.getMetadataPath)
- if (loadAvailable.exists(load => load.getSegmentStatus == SegmentStatus.INSERT_IN_PROGRESS ||
- load.getSegmentStatus == SegmentStatus.INSERT_OVERWRITE_IN_PROGRESS)) {
+ if (loadAvailable.exists(load => load.getVisibility().equalsIgnoreCase("true") &&
--- End diff --
Done
---