Github user kumarvishal09 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2606#discussion_r208460810
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/loading/steps/CarbonRowDataWriterProcessorStepImpl.java
---
@@ -169,38 +171,59 @@ private void doExecute(Iterator<CarbonRowBatch>
iterator, int iteratorIndex) thr
if (rowsNotExist) {
rowsNotExist = false;
dataHandler =
CarbonFactHandlerFactory.createCarbonFactHandler(model);
+ this.carbonFactHandlers.add(dataHandler);
dataHandler.initialise();
}
processBatch(iterator.next(), dataHandler, iteratorIndex);
}
- if (!rowsNotExist) {
- finish(dataHandler, iteratorIndex);
+ try {
+ if (!rowsNotExist) {
+ finish(dataHandler, iteratorIndex);
+ }
+ } catch (CarbonDataWriterException e) {
--- End diff --
remove this catch block
---
