Github user kumarvishal09 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/3046#discussion_r244708667
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/loading/steps/CarbonRowDataWriterProcessorStepImpl.java
---
@@ -128,16 +128,18 @@ public
CarbonRowDataWriterProcessorStepImpl(CarbonDataLoadConfiguration configur
CarbonTimeStatisticsFactory.getLoadStatisticsInstance()
.recordDictionaryValue2MdkAdd2FileTime(CarbonTablePath.DEPRECATED_PARTITION_ID,
System.currentTimeMillis());
-
+ ExecutorService fallBackExecutorService =
+ Executors.newFixedThreadPool(1, new
CarbonThreadFactory("FallBackPool:"));
--- End diff --
pool size cannot be always one ...please refer
org/apache/carbondata/processing/store/writer/AbstractFactDataWriter.java:203
---
