Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2290#discussion_r191447282
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonRecordReader.java ---
@@ -77,8 +77,10 @@ public void initialize(InputSplit inputSplit,
TaskAttemptContext context)
} else {
throw new RuntimeException("unsupported input split type: " +
inputSplit);
}
- List<TableBlockInfo> tableBlockInfoList =
CarbonInputSplit.createBlocks(splitList);
- queryModel.setTableBlockInfos(tableBlockInfoList);
+ if (queryModel.getTableBlockInfos().isEmpty()) {
--- End diff --
ok, done
---
