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
---