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