Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1566#discussion_r153094993
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/merger/CompactionResultSortProcessor.java
---
@@ -196,9 +196,16 @@ private void deleteTempStoreLocation() {
*/
private void processResult(List<RawResultIterator> resultIteratorList)
throws Exception {
for (RawResultIterator resultIterator : resultIteratorList) {
- while (resultIterator.hasNext()) {
-
addRowForSorting(prepareRowObjectForSorting(resultIterator.next()));
- isRecordFound = true;
+ if (CompactionType.STREAMING == compactionType) {
+ while (resultIterator.hasNext()) {
+ addRowForSorting(resultIterator.next());
--- End diff --
add comment to describe it is using raw row
---
