Github user ravipesala commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1324#discussion_r138863711
  
    --- Diff: 
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonInputFormat.java ---
    @@ -460,21 +460,22 @@ private BitSet setMatchedPartitions(String 
partitionIds, CarbonTable carbonTable
           for (DataRefNode dataRefNode : dataRefNodes) {
             BlockBTreeLeafNode leafNode = (BlockBTreeLeafNode) dataRefNode;
             TableBlockInfo tableBlockInfo = leafNode.getTableBlockInfo();
    +        String[] deleteDeltaFilePath = null;
             if (isIUDTable) {
               // In case IUD is not performed in this table avoid searching for
               // invalidated blocks.
               if (CarbonUtil
    -              .isInvalidTableBlock(tableBlockInfo.getSegmentId(), 
tableBlockInfo.getFilePath(),
    -                  invalidBlockVOForSegmentId, updateStatusManager)) {
    +                  .isInvalidTableBlock(tableBlockInfo.getSegmentId(), 
tableBlockInfo.getFilePath(),
    --- End diff --
    
    you can keep here , not an issue since this class going to be removed soon. 
Please do changes in `CarbonTableInputFormat`


---

Reply via email to