Github user ajantha-bhat commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2653#discussion_r212538635
--- 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 --
At SDK input level it self it is handled. negative numbers cannot come here.
But I will change.
---
