Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1367#discussion_r149945420
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonInputFormat.java ---
@@ -449,14 +449,14 @@ private BitSet setMatchedPartitions(String
partitionIds, CarbonTable carbonTable
//for each segment fetch blocks matching filter in Driver BTree
for (String segmentNo : getSegmentsToAccess(job)) {
- List<DataRefNode> dataRefNodes = getDataBlocksOfSegment(job,
filterExpressionProcessor,
- absoluteTableIdentifier, filterResolver, matchedPartitions,
segmentNo,
- cacheClient, updateStatusManager, partitionInfo);
// Get the UpdateVO for those tables on which IUD operations being
performed.
if (isIUDTable) {
invalidBlockVOForSegmentId =
updateStatusManager.getInvalidTimestampRange(segmentNo);
}
+ List<DataRefNode> dataRefNodes = getDataBlocksOfSegment(job,
filterExpressionProcessor,
--- End diff --
Not using CarbonInputFormat.java class, please use
CarbonTableInputFormat.java
---
