Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2207#discussion_r185525675
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/mutation/DeleteExecution.scala
---
@@ -127,12 +126,16 @@ object DeleteExecution {
var result = List[(SegmentStatus, (SegmentUpdateDetails,
ExecutionErrors))]()
while (records.hasNext) {
val ((key), (rowCountDetailsVO, groupedRows)) = records.next
+ val segmentId = key.substring(0,
key.indexOf(CarbonCommonConstants.FILE_SEPARATOR))
--- End diff --
Not possible as in above method it adds segmentid.
---
