Github user kumarvishal09 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/3029#discussion_r244331702
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/CarbonMergerRDD.scala
---
@@ -207,18 +212,34 @@ class CarbonMergerRDD[K, V](
carbonMergerMapping.campactionType,
factTableName,
partitionSpec)
+
+ } else if (CarbonCompactionUtil
+ .anyUnsortedOrRestructuredBlocks(rawResultIteratorList,
rawResultIteratorBooleanMap)) {
+
+ LOGGER.info("HybridSortProcessor flow is selected")
+ processor = new HybridSortProcessor(
+ carbonLoadModel,
+ carbonTable,
+ segmentProperties,
+ carbonMergerMapping.campactionType,
+ factTableName,
+ partitionSpec,
+ rawResultIteratorBooleanMap)
+
} else {
+
LOGGER.info("RowResultMergerProcessor flow is selected")
- processor =
- new RowResultMergerProcessor(
- databaseName,
- factTableName,
- segmentProperties,
- tempStoreLoc,
- carbonLoadModel,
- carbonMergerMapping.campactionType,
- partitionSpec)
+ processor = new RowResultMergerProcessor(
--- End diff --
revert this change
---
