You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@carbondata.apache.org by ravipesala <gi...@git.apache.org> on 2018/05/02 14:55:18 UTC

[GitHub] carbondata pull request #2207: [WIP] Support flat folder for managed carbon ...

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.


---