Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1891#discussion_r164954705
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonDeleteLoadByLoadDateCommand.scala
---
@@ -33,6 +35,12 @@ case class CarbonDeleteLoadByLoadDateCommand(
override def processData(sparkSession: SparkSession): Seq[Row] = {
Checker.validateTableExists(databaseNameOp, tableName, sparkSession)
val carbonTable = CarbonEnv.getCarbonTable(databaseNameOp,
tableName)(sparkSession)
+
+ // if insert overwrite in progress, do not allow delete segment
+ if (SegmentStatusManager.overwriteInProgressForTable(carbonTable)) {
--- End diff --
This is the bug
---
