Github user kunal642 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2295#discussion_r188847413
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateListeners.scala
---
@@ -569,9 +577,8 @@ object CommitPreAggregateListener extends
OperationEventListener with CommitHelp
if (commitFailed) {
sys.error("Failed to update table status for pre-aggregate table")
}
- }
-
-
+ operationContext.setProperty("commitComplete", !commitFailed)
--- End diff --
In case of any exception this will not get set and the load would be marked
as a success.
---
