Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2664#discussion_r213576004
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/loading/sort/impl/UnsafeBatchParallelReadMergeSorterImpl.java
---
@@ -62,12 +62,15 @@
private AtomicLong rowCounter;
+ private AtomicInteger batchId;
+
--- End diff --
please add test case to verify the query result---
