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
---
