Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2653#discussion_r212533573
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/CarbonDataProcessorUtil.java
---
@@ -659,9 +659,14 @@ public static boolean
isRawDataRequired(CarbonDataLoadConfiguration configuratio
* @return
*/
public static List<CarbonIterator<Object[]>>[]
partitionInputReaderIterators(
- CarbonIterator<Object[]>[] inputIterators) {
+ CarbonIterator<Object[]>[] inputIterators, short sdkUserCores) {
// Get the number of cores configured in property.
- int numberOfCores = CarbonProperties.getInstance().getNumberOfCores();
+ int numberOfCores;
+ if (sdkUserCores != 0) {
--- End diff --
check `sdkUserCores>0`
---
