Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2887#discussion_r229671196
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/loading/steps/DataWriterProcessorStepImpl.java
---
@@ -131,15 +130,15 @@ public CarbonFactDataHandlerModel
getDataHandlerModel() {
for (int j = 0; j < rangeExecutorServiceSubmitList.size(); j++) {
rangeExecutorServiceSubmitList.get(j).get();
}
- } catch (InterruptedException | ExecutionException e) {
+ } catch (InterruptedException e) {
throw new CarbonDataWriterException(e);
+ } catch (ExecutionException e) {
+ throw new CarbonDataWriterException(e.getCause());
--- End diff --
Here we get the exception in the thread by e.getCause
---
