Github user manishgupta88 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1812#discussion_r184397997
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonAlterTableCompactionCommand.scala
---
@@ -212,13 +224,18 @@ case class CarbonAlterTableCompactionCommand(
carbonLoadModel.setFactTimeStamp(loadStartTime)
val isCompactionTriggerByDDl = true
+ var segmentIds: Option[List[String]] = None
+ if (compactionType == CompactionType.CUSTOM &&
alterTableModel.customSegmentIds.isDefined) {
+ segmentIds = alterTableModel.customSegmentIds
+ }
--- End diff --
Modify the code to
val segmentIds: Option[List[String]] = if (compactionType ==
CompactionType.CUSTOM && alterTableModel.customSegmentIds.isDefined) {
alterTableModel.customSegmentIds
} else {
None
}
---
